Package | Description |
---|---|
org.apache.paimon.flink.sink |
Modifier and Type | Class and Description |
---|---|
class |
StoreCommitter
Committer for dynamic store. |
class |
StoreMultiCommitter
StoreMultiCommitter for multiple dynamic store. |
Modifier and Type | Field and Description |
---|---|
protected Committer<CommitT,GlobalCommitT> |
CommitterOperator.committer
Aggregate committables to global committables and commit the global committables to the
external system.
|
Modifier and Type | Method and Description |
---|---|
Committer<CommitT,GlobalCommitT> |
Committer.Factory.create(Committer.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
RestoreAndFailCommittableStateManager.initializeState(org.apache.flink.runtime.state.StateInitializationContext context,
Committer<?,GlobalCommitT> committer) |
void |
CommittableStateManager.initializeState(org.apache.flink.runtime.state.StateInitializationContext context,
Committer<?,GlobalCommitT> committer) |
void |
NoopCommittableStateManager.initializeState(org.apache.flink.runtime.state.StateInitializationContext context,
Committer<?,ManifestCommittable> committer) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.