Package org.apache.druid.indexer.partitions

Interface PartitionsSpec

All Known Subinterfaces:
DimensionBasedPartitionsSpec
All Known Implementing Classes:
DimensionRangePartitionsSpec, DynamicPartitionsSpec, HashedPartitionsSpec, SingleDimensionPartitionsSpec
public interface PartitionsSpec
PartitionsSpec describes the secondary partitioning method for data ingestion.

  • Field Details

  • Method Details

    • getType

      SecondaryPartitionType getType()

    • getMaxRowsPerSegment

      @Nullable Integer getMaxRowsPerSegment()
      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.

    • needsDeterminePartitions

      boolean needsDeterminePartitions(boolean useForHadoopTask)
      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.

    • isForceGuaranteedRollupCompatibleType

      default boolean isForceGuaranteedRollupCompatibleType()
      Returns:
      True if this partitionSpec's type is compatible with forceGuaranteedRollup=true.

    • isForceGuaranteedRollupCompatible

      default boolean isForceGuaranteedRollupCompatible()
      Returns:
      True if this partitionSpec's property values are compatible with forceGuaranteedRollup=true.

    • getForceGuaranteedRollupIncompatiblityReason

      String getForceGuaranteedRollupIncompatiblityReason()
      Returns:
      Message describing why this partitionSpec is incompatible with forceGuaranteedRollup=true. Empty string if the partitionSpec is compatible.

    • isEffectivelyNull

      static boolean isEffectivelyNull(@Nullable Integer val)
      '-1' regarded as null for some historical reason.

    • isEffectivelyNull

      static boolean isEffectivelyNull(@Nullable Long val)
      '-1' regarded as null for some historical reason.

    • resolveHistoricalNullIfNeeded

      @Nullable static Integer resolveHistoricalNullIfNeeded(@Nullable Integer val)