Package org.apache.druid.indexer.partitions

Class HashedPartitionsSpec

java.lang.Object

org.apache.druid.indexer.partitions.HashedPartitionsSpec

All Implemented Interfaces:

DimensionBasedPartitionsSpec, PartitionsSpec

public class HashedPartitionsSpec
extends Object
implements DimensionBasedPartitionsSpec

Field Summary

Fields

Modifier and Type	Field	Description
static final String	NAME

Fields inherited from interface org.apache.druid.indexer.partitions.DimensionBasedPartitionsSpec

ASSUME_GROUPED, FORCE_GUARANTEED_ROLLUP_COMPATIBLE, MAX_PARTITION_SIZE, PARTITION_DIMENSIONS, TARGET_PARTITION_SIZE, TARGET_ROWS_PER_SEGMENT

Fields inherited from interface org.apache.druid.indexer.partitions.PartitionsSpec

DEFAULT_MAX_ROWS_PER_SEGMENT, HISTORICAL_NULL, MAX_ROWS_PER_SEGMENT

Constructor Summary

Constructors

Constructor	Description
HashedPartitionsSpec(Integer maxRowsPerSegment, Integer numShards, List<String> partitionDimensions)
HashedPartitionsSpec(Integer maxRowsPerSegment, Integer numShards, List<String> partitionDimensions, HashPartitionFunction partitionFunction)
HashedPartitionsSpec(Integer targetRowsPerSegment, Integer numShards, List<String> partitionDimensions, HashPartitionFunction partitionFunction, Integer targetPartitionSize, Integer maxRowsPerSegment)

Method Summary

Modifier and Type	Method	Description
static HashedPartitionsSpec	defaultSpec()
boolean	equals(Object o)
String	getForceGuaranteedRollupIncompatiblityReason()
Integer	getMaxRowsPerSegment()	Returns the max number of rows per segment.
Integer	getNumShards()
List<String>	getPartitionDimensions()
HashPartitionFunction	getPartitionFunction()
Integer	getTargetRowsPerSegment()
SecondaryPartitionType	getType()
int	hashCode()
boolean	needsDeterminePartitions(boolean useForHadoopTask)	Returns true if this partitionsSpec needs to determine the number of partitions to start data ingestion.
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.indexer.partitions.PartitionsSpec

isForceGuaranteedRollupCompatible, isForceGuaranteedRollupCompatibleType

Field Details

NAME

public static final String NAME

See Also:

• Constant Field Values

Constructor Details

HashedPartitionsSpec

public HashedPartitionsSpec(@Nullable
 Integer targetRowsPerSegment,
 @Nullable
 Integer numShards,
 @Nullable
 List<String> partitionDimensions,
 @Nullable
 HashPartitionFunction partitionFunction,
 @Deprecated @Nullable
 Integer targetPartitionSize,
 @Deprecated @Nullable
 Integer maxRowsPerSegment)

HashedPartitionsSpec

public HashedPartitionsSpec(@Nullable
 Integer maxRowsPerSegment,
 @Nullable
 Integer numShards,
 @Nullable
 List<String> partitionDimensions,
 @Nullable
 HashPartitionFunction partitionFunction)

HashedPartitionsSpec

public HashedPartitionsSpec(@Nullable
 Integer maxRowsPerSegment,
 @Nullable
 Integer numShards,
 @Nullable
 List<String> partitionDimensions)

Method Details

defaultSpec

public static HashedPartitionsSpec defaultSpec()

getTargetRowsPerSegment

@Nullable
public Integer getTargetRowsPerSegment()

Specified by:

getTargetRowsPerSegment in interface DimensionBasedPartitionsSpec

getType

public SecondaryPartitionType getType()

Specified by:

getType in interface PartitionsSpec

getMaxRowsPerSegment

@Nullable
public Integer getMaxRowsPerSegment()

Description copied from interface: PartitionsSpec

Returns the max number of rows per segment. Implementations can have different default values which it could be even null. Callers should use the right value depending on the context if this returns null.

Specified by:

getMaxRowsPerSegment in interface PartitionsSpec

needsDeterminePartitions

public boolean needsDeterminePartitions(boolean useForHadoopTask)

Description copied from interface: PartitionsSpec

Returns true if this partitionsSpec needs to determine the number of partitions to start data ingestion. It should usually return true if perfect rollup is enforced but number of partitions is not specified.

Specified by:

needsDeterminePartitions in interface PartitionsSpec

getNumShards

@Nullable
public Integer getNumShards()

getPartitionDimensions

public List<String> getPartitionDimensions()

Specified by:

getPartitionDimensions in interface DimensionBasedPartitionsSpec

getPartitionFunction

public HashPartitionFunction getPartitionFunction()

getForceGuaranteedRollupIncompatiblityReason

public String getForceGuaranteedRollupIncompatiblityReason()

Specified by:

getForceGuaranteedRollupIncompatiblityReason in interface PartitionsSpec

Returns:

Message describing why this partitionSpec is incompatible with forceGuaranteedRollup=true. Empty string if the partitionSpec is compatible.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object