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, int parallelism, int subtaskIndex)

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(CatalogLoader catalogLoader, Committer.Context context)
StoreMultiCommitter(CatalogLoader catalogLoader, Committer.Context context, boolean ignoreEmptyCommit, Map<String,String> dynamicOptions)
StoreMultiCommitter(CatalogLoader catalogLoader, Committer.Context context, boolean ignoreEmptyCommit, Map<String,String> dynamicOptions, boolean eagerInit, TableFilter tableFilter)

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)