Package org.apache.iceberg.flink.maintenance.operator

Class TriggerEvaluator.Builder

java.lang.Object

org.apache.iceberg.flink.maintenance.operator.TriggerEvaluator.Builder

All Implemented Interfaces:

Serializable

Enclosing class:

TriggerEvaluator

public static class TriggerEvaluator.Builder
extends Object
implements Serializable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
TriggerEvaluator	build()
TriggerEvaluator.Builder	commitCount(int newCommitCount)
TriggerEvaluator.Builder	dataFileCount(int newDataFileCount)
TriggerEvaluator.Builder	dataFileSizeInBytes(long neDataFileSizeInBytes)
TriggerEvaluator.Builder	eqDeleteFileCount(int newEqDeleteFileCount)
TriggerEvaluator.Builder	eqDeleteRecordCount(long newEqDeleteRecordCount)
TriggerEvaluator.Builder	posDeleteFileCount(int newPosDeleteFileCount)
TriggerEvaluator.Builder	posDeleteRecordCount(long newPosDeleteRecordCount)
TriggerEvaluator.Builder	timeout(Duration newTimeout)

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

dataFileCount

public TriggerEvaluator.Builder dataFileCount(int newDataFileCount)

dataFileSizeInBytes

public TriggerEvaluator.Builder dataFileSizeInBytes(long neDataFileSizeInBytes)

posDeleteFileCount

public TriggerEvaluator.Builder posDeleteFileCount(int newPosDeleteFileCount)

posDeleteRecordCount

public TriggerEvaluator.Builder posDeleteRecordCount(long newPosDeleteRecordCount)

eqDeleteFileCount

public TriggerEvaluator.Builder eqDeleteFileCount(int newEqDeleteFileCount)

eqDeleteRecordCount

public TriggerEvaluator.Builder eqDeleteRecordCount(long newEqDeleteRecordCount)

commitCount

public TriggerEvaluator.Builder commitCount(int newCommitCount)

timeout

public TriggerEvaluator.Builder timeout(Duration newTimeout)

build

public TriggerEvaluator build()