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

Packages that use Committer.Context

Package	Description
org.apache.paimon.flink.sink
org.apache.paimon.flink.sink.partition

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)

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

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

Modifier and Type	Method and Description
static PartitionListeners	PartitionListeners.create(Committer.Context context, FileStoreTable table)