Package 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:

ShardSpec

public class HashBasedNumberedShardSpec
extends NumberedShardSpec

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.druid.timeline.partition.ShardSpec

ShardSpec.Type

Field Summary

Fields

Modifier and Type	Field	Description
static final List<String>	DEFAULT_PARTITION_DIMENSIONS

Constructor Summary

Constructors

Constructor	Description
HashBasedNumberedShardSpec(int partitionNum, int partitions, Integer bucketId, Integer numBuckets, List<String> partitionDimensions, HashPartitionFunction partitionFunction, com.fasterxml.jackson.databind.ObjectMapper jsonMapper)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
int	getBucketId()
List<String>	getDomainDimensions()	Get dimensions who have possible range for the rows this shard contains.
ShardSpecLookup	getLookup(List<? extends ShardSpec> shardSpecs)
int	getNumBuckets()
List<String>	getPartitionDimensions()
HashPartitionFunction	getPartitionFunction()
String	getType()	Get the type name of this ShardSpec.
int	hashCode()
boolean	possibleInDomain(Map<String,com.google.common.collect.RangeSet<String>> domain)	if given domain ranges are not possible in this shard, return false; otherwise return true;
static byte[]	serializeGroupKey(com.fasterxml.jackson.databind.ObjectMapper jsonMapper, List<Object> partitionKeys)	Serializes a group key into a byte array.
String	toString()

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

canCreateNumberedPartitionChunk, createChunk, getNumCorePartitions, getPartitionNum, withCorePartitions, withPartitionNum

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.timeline.partition.ShardSpec

getAtomicUpdateGroupSize, getDomainVirtualColumns, getEndRootPartitionId, getMinorVersion, getStartRootPartitionId, sharePartitionSpace

Field Details

DEFAULT_PARTITION_DIMENSIONS

public static final List<String> DEFAULT_PARTITION_DIMENSIONS

Constructor Details

HashBasedNumberedShardSpec

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

Method Details

getBucketId

public int getBucketId()

getNumBuckets

public int getNumBuckets()

getPartitionDimensions

public List<String> getPartitionDimensions()

getPartitionFunction

@Nullable
public HashPartitionFunction getPartitionFunction()

getDomainDimensions

public List<String> getDomainDimensions()

Description copied from interface: ShardSpec

Get dimensions who have possible range for the rows this shard contains. These columns might be physical columns stored in the shard, or computed expressions, in which case the manner in which they were computed is available in ShardSpec.getDomainVirtualColumns().

Specified by:

getDomainDimensions in interface ShardSpec

Overrides:

getDomainDimensions in class NumberedShardSpec

Returns:

list of dimensions who has its possible range. Dimensions with unknown possible range are not listed.

getLookup

public ShardSpecLookup getLookup(List<? extends ShardSpec> shardSpecs)

Specified by:

getLookup in interface ShardSpec

Overrides:

getLookup in class NumberedShardSpec

possibleInDomain

public boolean possibleInDomain(Map<String,com.google.common.collect.RangeSet<String>> domain)

Description copied from interface: ShardSpec

if given domain ranges are not possible in this shard, return false; otherwise return true;

Specified by:

possibleInDomain in interface ShardSpec

Overrides:

possibleInDomain in class NumberedShardSpec

Returns:

possibility of in domain

serializeGroupKey

public static byte[] serializeGroupKey(com.fasterxml.jackson.databind.ObjectMapper jsonMapper,
 List<Object> partitionKeys)

Serializes a group key into a byte array. The serialization algorithm can affect hash values of partition keys since HashPartitionFunction.hash(byte[], int) takes the result of this method as its input. This means, the returned byte array should be backwards-compatible in cases where we need to modify this method.

getType

public String getType()

Description copied from interface: ShardSpec

Get the type name of this ShardSpec.

Specified by:

getType in interface ShardSpec

Overrides:

getType in class NumberedShardSpec

equals

public boolean equals(Object o)

Overrides:

equals in class NumberedShardSpec

hashCode

public int hashCode()

Overrides:

hashCode in class NumberedShardSpec

toString

public String toString()

Overrides:

toString in class NumberedShardSpec