com.yahoo.bard.webservice.druid.model.metadata

Class NumberedShardSpec

java.lang.Object

com.yahoo.bard.webservice.druid.model.metadata.NumberedShardSpec

All Implemented Interfaces:

io.druid.timeline.partition.ShardSpec

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

NumberedShardSpec class. Reflects the current shardspec type that is used in druid datasource metadata endpoints.

Constructor Summary

Constructors

Constructor and Description
NumberedShardSpec(io.druid.timeline.partition.NoneShardSpec spec) Creates numbered shard spec from an unsharded spec.
NumberedShardSpec(String type, int partitionNum, int partitions) Creates a numbered shard specification given a type, a partition number and the total number of partitions.

Method Summary

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() Getter for partition number.
int	getPartitions() Getter for the number of partitions.
String	getType() Getter for type.
boolean	isInChunk(long timestamp, io.druid.data.input.InputRow inputRow)

Methods inherited from class java.lang.Object

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

Constructor Detail

NumberedShardSpec

public NumberedShardSpec(String type,
                         int partitionNum,
                         int partitions)

Creates a numbered shard specification given a type, a partition number and the total number of partitions.

Parameters:

type - The type of this shard spec.

partitionNum - The partition number of this shard spec.

partitions - The total number of partitions of the segment that this shard spec belongs to.

NumberedShardSpec

public NumberedShardSpec(io.druid.timeline.partition.NoneShardSpec spec)

Creates numbered shard spec from an unsharded spec. Consequently the numbered shard spec will have type: "none", partition number equal to zero and number of partitions equal to one.

Parameters:

spec - The spec corresponding to unsharded segment.

Method Detail

getType

public String getType()

Getter for type.

Returns:

type The type of this shard spec.

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

getPartitionNum

public int getPartitionNum()

Getter for partition number.

Specified by:

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

Returns:

The partition number of this shard spec.

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()

Getter for the number of partitions.

Returns:

The number of partitions of the segment that this shard belongs to.