io.druid.timeline.partition

Class HashBasedNumberedShardSpec

java.lang.Object

io.druid.timeline.partition.NumberedShardSpec

io.druid.timeline.partition.HashBasedNumberedShardSpec

All Implemented Interfaces:

io.druid.timeline.partition.ShardSpec

public class HashBasedNumberedShardSpec
extends NumberedShardSpec

Constructor Summary

Constructors

Constructor and Description
HashBasedNumberedShardSpec(int partitionNum, int partitions, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Methods

Modifier and Type	Method and Description
io.druid.timeline.partition.ShardSpecLookup	getLookup(List<io.druid.timeline.partition.ShardSpec> shardSpecs)
protected int	hash(long timestamp, io.druid.data.input.InputRow inputRow)
boolean	isInChunk(long timestamp, io.druid.data.input.InputRow inputRow)
String	toString()

Methods inherited from class io.druid.timeline.partition.NumberedShardSpec

createChunk, getPartitionNum, getPartitions

Methods inherited from class java.lang.Object

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

Constructor Detail

HashBasedNumberedShardSpec

public HashBasedNumberedShardSpec(int partitionNum,
                          int partitions,
                          com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

isInChunk

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

Specified by:

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

Overrides:

isInChunk in class NumberedShardSpec

hash

protected int hash(long timestamp,
       io.druid.data.input.InputRow inputRow)

toString

public String toString()

Overrides:

toString in class NumberedShardSpec

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

Overrides:

getLookup in class NumberedShardSpec