Package org.apache.gravitino.dto.policy

Class PolicyContentDTO.IcebergCompactionContentDTO

java.lang.Object
org.apache.gravitino.dto.policy.PolicyContentDTO.IcebergCompactionContentDTO
All Implemented Interfaces:
PolicyContentDTO, PolicyContent
Enclosing interface:
PolicyContentDTO
public static class PolicyContentDTO.IcebergCompactionContentDTO extends Object implements PolicyContentDTO
Represents a typed iceberg compaction policy content DTO.

  • Method Details

    • minDataFileMse

      public Long minDataFileMse()
      Returns the minimum threshold for custom-data-file-mse metric.
      Returns:
      minimum data file MSE threshold

    • minDeleteFileNumber

      public Long minDeleteFileNumber()
      Returns the minimum threshold for custom-delete-file-number metric.
      Returns:
      minimum delete file number threshold

    • dataFileMseWeight

      public Long dataFileMseWeight()
      Returns the weight for custom-data-file-mse metric in score expression.
      Returns:
      data file MSE score weight

    • deleteFileNumberWeight

      public Long deleteFileNumberWeight()
      Returns the weight for custom-delete-file-number metric in score expression.
      Returns:
      delete file number score weight

    • maxPartitionNum

      public Long maxPartitionNum()
      Returns max partition number selected for compaction.
      Returns:
      max partition number

    • rewriteOptions

      public Map<String,String> rewriteOptions()
      Returns rewrite options expanded to job.options.* during rule generation.
      Returns:
      rewrite options map

    • supportedObjectTypes

      public Set<MetadataObject.Type> supportedObjectTypes()
      Specified by:
      supportedObjectTypes in interface PolicyContent
      Returns:
      the set of metadata object types that the policy can be applied to

    • properties

      public Map<String,String> properties()
      Specified by:
      properties in interface PolicyContent
      Returns:
      The additional properties of the policy.

    • rules

      public Map<String,Object> rules()
      Description copied from interface: PolicyContent
      A convenience method to get all rules in the policy content.
      Specified by:
      rules in interface PolicyContent
      Returns:
      A map of rule names to their corresponding rule objects.

    • validate

      public void validate() throws IllegalArgumentException
      Description copied from interface: PolicyContent
      Validates the policy content.
      Specified by:
      validate in interface PolicyContent
      Throws:
      IllegalArgumentException - if the content is invalid.