Package org.apache.iceberg.flink.maintenance.api

Class TableMaintenance.Builder

java.lang.Object

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

Enclosing class:

TableMaintenance

public static class TableMaintenance.Builder
extends Object

Method Summary

Modifier and Type	Method	Description
TableMaintenance.Builder	add(MaintenanceTaskBuilder<?> task)	Adds a specific task with the given schedule.
void	append()	Builds the task graph for the maintenance tasks.
TableMaintenance.Builder	lockCheckDelay(Duration newLockCheckDelay)	Sets the delay for checking lock availability when a concurrent run is detected.
TableMaintenance.Builder	maxReadBack(int newMaxReadBack)	Maximum number of snapshots checked when started with an embedded MonitorSource at the first time.
TableMaintenance.Builder	parallelism(int newParallelism)	Sets the default parallelism of maintenance tasks.
TableMaintenance.Builder	rateLimit(Duration newRateLimit)	Limits the firing frequency for the task triggers.
TableMaintenance.Builder	slotSharingGroup(String newSlotSharingGroup)	The SingleOutputStreamOperator.slotSharingGroup(String) for all the operators of the generated stream.
TableMaintenance.Builder	uidSuffix(String newUidSuffix)	The suffix used for the generated Transformation's uid.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

uidSuffix

public TableMaintenance.Builder uidSuffix(String newUidSuffix)

The suffix used for the generated Transformation's uid.

Parameters:

newUidSuffix - for the transformations

slotSharingGroup

public TableMaintenance.Builder slotSharingGroup(String newSlotSharingGroup)

The SingleOutputStreamOperator.slotSharingGroup(String) for all the operators of the generated stream. Could be used to separate the resources used by this task.

Parameters:

newSlotSharingGroup - to be used for the operators

rateLimit

public TableMaintenance.Builder rateLimit(Duration newRateLimit)

Limits the firing frequency for the task triggers.

Parameters:

newRateLimit - firing frequency

lockCheckDelay

public TableMaintenance.Builder lockCheckDelay(Duration newLockCheckDelay)

Sets the delay for checking lock availability when a concurrent run is detected.

Parameters:

newLockCheckDelay - lock checking frequency

parallelism

public TableMaintenance.Builder parallelism(int newParallelism)

Sets the default parallelism of maintenance tasks. Could be overwritten by the MaintenanceTaskBuilder.parallelism(int).

Parameters:

newParallelism - task parallelism

maxReadBack

public TableMaintenance.Builder maxReadBack(int newMaxReadBack)

Maximum number of snapshots checked when started with an embedded MonitorSource at the first time. Only available when the TableMaintenance.forTable(StreamExecutionEnvironment, TableLoader, TriggerLockFactory) is used.

Parameters:

newMaxReadBack - snapshots to consider when initializing

add

public TableMaintenance.Builder add(MaintenanceTaskBuilder<?> task)

Adds a specific task with the given schedule.

Parameters:

task - to add

append

public void append()
            throws IOException

Builds the task graph for the maintenance tasks.

Throws:

IOException