org.apache.druid.timeline.partition

Class LinearShardSpec

java.lang.Object

org.apache.druid.timeline.partition.LinearShardSpec

All Implemented Interfaces:

org.apache.druid.timeline.partition.ShardSpec

public class LinearShardSpec
extends Object
implements org.apache.druid.timeline.partition.ShardSpec

An extendable linear shard spec. partitionNum represents an unique id of a partition.

Constructor Summary

Constructors

Constructor and Description
LinearShardSpec(Integer partitionNum)

Method Summary

Modifier and Type	Method and Description
<T> org.apache.druid.timeline.partition.PartitionChunk<T>	createChunk(T obj)
List<String>	getDomainDimensions()
org.apache.druid.timeline.partition.ShardSpecLookup	getLookup(List<org.apache.druid.timeline.partition.ShardSpec> shardSpecs)
int	getPartitionNum()
boolean	isInChunk(long timestamp, org.apache.druid.data.input.InputRow inputRow)
boolean	possibleInDomain(Map<String,com.google.common.collect.RangeSet<String>> domain)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

LinearShardSpec

public LinearShardSpec(Integer partitionNum)

Method Detail

getPartitionNum

public int getPartitionNum()

Specified by:

getPartitionNum in interface org.apache.druid.timeline.partition.ShardSpec

getLookup

public org.apache.druid.timeline.partition.ShardSpecLookup getLookup(List<org.apache.druid.timeline.partition.ShardSpec> shardSpecs)

Specified by:

getLookup in interface org.apache.druid.timeline.partition.ShardSpec

getDomainDimensions

public List<String> getDomainDimensions()

Specified by:

getDomainDimensions in interface org.apache.druid.timeline.partition.ShardSpec

possibleInDomain

public boolean possibleInDomain(Map<String,com.google.common.collect.RangeSet<String>> domain)

Specified by:

possibleInDomain in interface org.apache.druid.timeline.partition.ShardSpec

createChunk

public <T> org.apache.druid.timeline.partition.PartitionChunk<T> createChunk(T obj)

Specified by:

createChunk in interface org.apache.druid.timeline.partition.ShardSpec

isInChunk

public boolean isInChunk(long timestamp,
                         org.apache.druid.data.input.InputRow inputRow)

Specified by:

isInChunk in interface org.apache.druid.timeline.partition.ShardSpec

toString

public String toString()

Overrides:

toString in class Object