ConvertEqualityDeletes.Builder

java.lang.Object

org.apache.iceberg.flink.maintenance.api.MaintenanceTaskBuilder<ConvertEqualityDeletes.Builder>

org.apache.iceberg.flink.maintenance.api.ConvertEqualityDeletes.Builder

Enclosing class:: ConvertEqualityDeletes

public static class ConvertEqualityDeletes.Builder extends MaintenanceTaskBuilder<ConvertEqualityDeletes.Builder>

Constructor Summary

Constructors

Constructor

Description

Builder()
Method Summary

Modifier and Type

Method

Description

ConvertEqualityDeletes.Builder

config(ConvertEqualityDeletesConfig config)

Configures the scheduling of the conversion.

ConvertEqualityDeletes.Builder

equalityFieldColumns(List<String> columns)

Sets the equality field columns used by the worker index.

ConvertEqualityDeletes.Builder

stagingBranch(String newStagingBranch)

Sets the staging branch name that holds the equality delete files and data files.

ConvertEqualityDeletes.Builder

targetBranch(String newTargetBranch)

Sets the target branch where converted data files and DVs are committed.

Methods inherited from class org.apache.iceberg.flink.maintenance.api.MaintenanceTaskBuilder
index, operatorName, parallelism, parallelism, scheduleOnCommitCount, scheduleOnDataFileCount, scheduleOnDataFileSize, scheduleOnEqDeleteFileCount, scheduleOnEqDeleteRecordCount, scheduleOnInterval, scheduleOnPosDeleteFileCount, scheduleOnPosDeleteRecordCount, slotSharingGroup, slotSharingGroup, tableLoader, tableName, taskName, uidSuffix, uidSuffix

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- Builder
  
  public Builder()
Method Details
- stagingBranch
  
  public ConvertEqualityDeletes.Builder stagingBranch(String newStagingBranch)
  
  Sets the staging branch name that holds the equality delete files and data files.
- targetBranch
  
  public ConvertEqualityDeletes.Builder targetBranch(String newTargetBranch)
  
  Sets the target branch where converted data files and DVs are committed. Defaults to the main branch.
- equalityFieldColumns
  
  public ConvertEqualityDeletes.Builder equalityFieldColumns(List<String> columns)
  
  Sets the equality field columns used by the worker index. Required. Must match the equality field columns the writer uses for staging eq-delete files. Mirrors IcebergSink.Builder.equalityFieldColumns.
  The partition source columns of an equality delete's spec must be a subset of these columns. Writes via Flink's IcebergSink already ensure this.
- config
  
  public ConvertEqualityDeletes.Builder config(ConvertEqualityDeletesConfig config)
  
  Configures the scheduling of the conversion.
  
  Parameters:
  
  config - properties for the conversion, see ConvertEqualityDeletesConfig for available keys