io.druid.timeline.partition

Class NumberedShardSpec

java.lang.Object

io.druid.timeline.partition.NumberedShardSpec

All Implemented Interfaces:

io.druid.timeline.partition.ShardSpec

Direct Known Subclasses:

HashBasedNumberedShardSpec

public class NumberedShardSpec
extends Object
implements io.druid.timeline.partition.ShardSpec

Constructor Summary

Constructors

Constructor and Description
NumberedShardSpec(int partitionNum, int partitions)

Method Summary

Methods

Modifier and Type	Method and Description
<T> io.druid.timeline.partition.PartitionChunk<T>	createChunk(T obj)
io.druid.timeline.partition.ShardSpecLookup	getLookup(List<io.druid.timeline.partition.ShardSpec> shardSpecs)
int	getPartitionNum()
int	getPartitions()
boolean	isInChunk(long timestamp, io.druid.data.input.InputRow inputRow)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

NumberedShardSpec

public NumberedShardSpec(int partitionNum,
                 int partitions)

Method Detail

getPartitionNum

public int getPartitionNum()

Specified by:

getPartitionNum in interface io.druid.timeline.partition.ShardSpec

getLookup

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

Specified by:

getLookup in interface io.druid.timeline.partition.ShardSpec

getPartitions

public int getPartitions()

createChunk

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

Specified by:

createChunk in interface io.druid.timeline.partition.ShardSpec

isInChunk

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

Specified by:

isInChunk in interface io.druid.timeline.partition.ShardSpec

toString

public String toString()

Overrides:

toString in class Object