Package org.apache.iceberg.actions

Class FileRewritePlan<I,T extends ContentScanTask<F>,F extends ContentFile<F>,G extends RewriteGroupBase<I,T,F>>

java.lang.Object
org.apache.iceberg.actions.FileRewritePlan<I,T,F,G>
Type Parameters:
I - the Java type of the plan info like RewriteDataFiles.FileGroupInfo or RewritePositionDeleteFiles.FileGroupInfo
T - the Java type of the input scan tasks (input)
F - the Java type of the content files (input and output)
G - the Java type of the rewrite file group like RewriteFileGroup or RewritePositionDeletesGroup
public class FileRewritePlan<I,T extends ContentScanTask<F>,F extends ContentFile<F>,G extends RewriteGroupBase<I,T,F>> extends Object
Container class holding the output of a FileRewritePlanner.plan() call. Contains a list of groups (See: RewriteFileGroup and RewritePositionDeletesGroup) which are used by engines to rewrite a particular set of files.

  • Method Details

    • groups

      public CloseableIterable<G> groups()
      The stream of the generated RewriteGroupBases.

    • groupsInPartition

      public int groupsInPartition(StructLike partition)
      The number of the generated groups in the given partition.

    • totalGroupCount

      public int totalGroupCount()
      The total number of the groups generated by this plan.