Class LinearPartialShardSpec

java.lang.Object
org.apache.druid.timeline.partition.LinearPartialShardSpec
All Implemented Interfaces:
PartialShardSpec

public class LinearPartialShardSpec extends Object implements PartialShardSpec
  • Method Details

    • instance

      public static LinearPartialShardSpec instance()
    • 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