org.apache.druid.timeline.partition

Class NumberedShardSpec

java.lang.Object

org.apache.druid.timeline.partition.NumberedShardSpec

All Implemented Interfaces:

org.apache.druid.timeline.partition.ShardSpec

Direct Known Subclasses:

HashBasedNumberedShardSpec

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

An extendable linear shard spec containing the information of core partitions. This class contains two variables of partitionNum and partitions, which represent the unique id of a partition and the number of core partitions, respectively. partitions simply indicates that the atomic update is regarded as completed when partitions partitions are successfully updated, and partitionNum can go beyond it when some types of index tasks are trying to append to existing partitions.

Constructor Summary

Constructors

Constructor and Description
NumberedShardSpec(int partitionNum, int partitions)

Method Summary

Modifier and Type	Method and Description
<T> org.apache.druid.timeline.partition.PartitionChunk<T>	createChunk(T obj)
boolean	equals(Object o)
List<String>	getDomainDimensions()
org.apache.druid.timeline.partition.ShardSpecLookup	getLookup(List<org.apache.druid.timeline.partition.ShardSpec> shardSpecs)
int	getPartitionNum()
int	getPartitions()
int	hashCode()
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, finalize, getClass, 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 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

getPartitions

public int getPartitions()

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

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object