Package org.apache.druid.timeline.partition

Class NumberedOverwritePartialShardSpec

java.lang.Object

org.apache.druid.timeline.partition.NumberedOverwritePartialShardSpec

All Implemented Interfaces:

PartialShardSpec

public class NumberedOverwritePartialShardSpec
extends Object
implements PartialShardSpec

Constructor Summary

Constructors

Constructor	Description
NumberedOverwritePartialShardSpec(int startRootPartitionId, int endRootPartitionId, int minorVersion)
NumberedOverwritePartialShardSpec(int startRootPartitionId, int endRootPartitionId, short minorVersion)

Method Summary

Modifier and Type	Method	Description
ShardSpec	complete(com.fasterxml.jackson.databind.ObjectMapper objectMapper, int partitionId, int numCorePartitions)	Creates a new ShardSpec with given partitionId and numCorePartitions.
int	getEndRootPartitionId()
short	getMinorVersion()
Class<? extends ShardSpec>	getShardSpecClass()	Returns the class of the shardSpec created by this factory.
int	getStartRootPartitionId()
boolean	useNonRootGenerationPartitionSpace()	Returns true if this partialShardSpec needs a partitionId of a non-root generation.

Methods inherited from class java.lang.Object

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

Constructor Details

NumberedOverwritePartialShardSpec

public NumberedOverwritePartialShardSpec(int startRootPartitionId,
 int endRootPartitionId,
 short minorVersion)

NumberedOverwritePartialShardSpec

public NumberedOverwritePartialShardSpec(int startRootPartitionId,
 int endRootPartitionId,
 int minorVersion)

Method Details

getStartRootPartitionId

public int getStartRootPartitionId()

getEndRootPartitionId

public int getEndRootPartitionId()

getMinorVersion

public short getMinorVersion()

complete

public ShardSpec complete(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 int partitionId,
 int numCorePartitions)

Description copied from interface: PartialShardSpec

Creates a new ShardSpec with given partitionId and numCorePartitions.

Specified by:

complete in interface PartialShardSpec

Parameters:

objectMapper - jsonMapper used only for HashBasedNumberedShardSpec

partitionId - partitionId of the shardSpec. must be carefully chosen to be unique in a time chunk

numCorePartitions - the core partition set size. Should be set properly to determine if this segment belongs to the core partitions.

getShardSpecClass

public Class<? extends ShardSpec> getShardSpecClass()

Description copied from interface: PartialShardSpec

Returns the class of the shardSpec created by this factory.

Specified by:

getShardSpecClass in interface PartialShardSpec

useNonRootGenerationPartitionSpace

public boolean useNonRootGenerationPartitionSpace()

Description copied from interface: PartialShardSpec

Returns true if this partialShardSpec needs a partitionId of a non-root generation. Any partialShardSpec to overwrite a subset of segments in a time chunk such as NumberedOverwritePartialShardSpec should return true.

Specified by:

useNonRootGenerationPartitionSpace in interface PartialShardSpec

See Also:

• PartitionIds