io.druid.timeline.partition

Class HashBasedNumberedShardSpec

java.lang.Object

io.druid.timeline.partition.NumberedShardSpec

io.druid.timeline.partition.HashBasedNumberedShardSpec

All Implemented Interfaces:

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
Map<String,com.google.common.collect.Range<String>>	getDomain() Get the possible range of each dimension for the rows this shard contains.
ShardSpecLookup	getLookup(List<ShardSpec> shardSpecs)
List<String>	getPartitionDimensions()
protected int	hash(long timestamp, InputRow inputRow)
boolean	isInChunk(long timestamp, 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,
                                  @Nullable
                                  List<String> partitionDimensions,
                                  com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Detail

getPartitionDimensions

public List<String> getPartitionDimensions()

isInChunk

public boolean isInChunk(long timestamp,
                         InputRow inputRow)

Specified by:

isInChunk in interface ShardSpec

Overrides:

isInChunk in class NumberedShardSpec

hash

protected int hash(long timestamp,
                   InputRow inputRow)

toString

public String toString()

Overrides:

toString in class NumberedShardSpec

getLookup

public ShardSpecLookup getLookup(List<ShardSpec> shardSpecs)

Specified by:

getLookup in interface ShardSpec

Overrides:

getLookup in class NumberedShardSpec

getDomain

public Map<String,com.google.common.collect.Range<String>> getDomain()

Description copied from interface: ShardSpec

Get the possible range of each dimension for the rows this shard contains.

Specified by:

getDomain in interface ShardSpec

Overrides:

getDomain in class NumberedShardSpec

Returns:

map of dimensions to its possible range. Dimensions with unknown possible range are not mapped