org.apache.paimon.flink.sink

Interface Committer.Context

Enclosing interface:

Committer<CommitT,GlobalCommitT>

public static interface Committer.Context

Context to create Committer.

Method Summary

Modifier and Type	Method and Description
String	commitUser()
boolean	isRestored()
org.apache.flink.metrics.groups.OperatorMetricGroup	metricGroup()
org.apache.flink.api.common.state.OperatorStateStore	stateStore()
boolean	streamingCheckpointEnabled()

Method Detail

commitUser

String commitUser()

metricGroup

@Nullable
org.apache.flink.metrics.groups.OperatorMetricGroup metricGroup()

streamingCheckpointEnabled

boolean streamingCheckpointEnabled()

isRestored

boolean isRestored()

stateStore

org.apache.flink.api.common.state.OperatorStateStore stateStore()