org.apache.druid.timeline.partition

Class HashBasedNumberedShardSpec

java.lang.Object

org.apache.druid.timeline.partition.NumberedShardSpec

org.apache.druid.timeline.partition.HashBasedNumberedShardSpec

All Implemented Interfaces:

org.apache.druid.timeline.partition.ShardSpec

public class HashBasedNumberedShardSpec
extends NumberedShardSpec

Constructor Summary

Constructors

Constructor and Description
HashBasedNumberedShardSpec(int partitionNum, int partitions, List<String> partitionDimensions, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method and Description
org.apache.druid.timeline.partition.ShardSpecLookup	getLookup(List<org.apache.druid.timeline.partition.ShardSpec> shardSpecs)
List<String>	getPartitionDimensions()
protected int	hash(long timestamp, org.apache.druid.data.input.InputRow inputRow)
static int	hash(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, List<Object> objects)
boolean	isInChunk(long timestamp, org.apache.druid.data.input.InputRow inputRow)
String	toString()

Methods inherited from class org.apache.druid.timeline.partition.NumberedShardSpec

createChunk, equals, getDomainDimensions, getPartitionNum, getPartitions, hashCode, possibleInDomain

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

HashBasedNumberedShardSpec

public HashBasedNumberedShardSpec(int partitionNum,
                                  int partitions,
                                  @Nullable
                                  List<String> partitionDimensions,
                                  com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

getPartitionDimensions

public List<String> getPartitionDimensions()

isInChunk

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

Specified by:

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

Overrides:

isInChunk in class NumberedShardSpec

hash

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

hash

public static int hash(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
                       List<Object> objects)
                throws com.fasterxml.jackson.core.JsonProcessingException

Throws:

com.fasterxml.jackson.core.JsonProcessingException

toString

public String toString()

Overrides:

toString in class NumberedShardSpec

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

Overrides:

getLookup in class NumberedShardSpec