Uses of Interface
org.apache.paimon.flink.sink.Committer.Context

Packages that use Committer.Context

Package	Description
org.apache.paimon.flink.sink

Uses of Committer.Context in org.apache.paimon.flink.sink

Methods in org.apache.paimon.flink.sink that return Committer.Context

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

Methods in org.apache.paimon.flink.sink with parameters of type Committer.Context

Modifier and Type	Method and Description
Committer<CommitT,GlobalCommitT>	Committer.Factory.create(Committer.Context context)

Constructors in org.apache.paimon.flink.sink with parameters of type Committer.Context

Constructor and Description
StoreCommitter(FileStoreTable table, TableCommit commit, Committer.Context context)
StoreMultiCommitter(Catalog.Loader catalogLoader, Committer.Context context)
StoreMultiCommitter(Catalog.Loader catalogLoader, Committer.Context context, boolean ignoreEmptyCommit, Map<String,String> dynamicOptions)