Package | Description |
---|---|
org.apache.flink.table.store.connector.sink |
Modifier and Type | Class and Description |
---|---|
class |
StoreCommitter
Committer for dynamic store. |
Modifier and Type | Field and Description |
---|---|
protected Committer |
CommitterOperator.committer
Aggregate committables to global committables and commit the global committables to the
external system.
|
Modifier and Type | Method and Description |
---|---|
protected abstract org.apache.flink.util.function.SerializableFunction<String,Committer> |
FlinkSink.createCommitterFactory(boolean streamingCheckpointEnabled) |
protected org.apache.flink.util.function.SerializableFunction<String,Committer> |
FileStoreSink.createCommitterFactory(boolean streamingCheckpointEnabled) |
protected org.apache.flink.util.function.SerializableFunction<String,Committer> |
CompactorSink.createCommitterFactory(boolean streamingCheckpointEnabled) |
Modifier and Type | Method and Description |
---|---|
void |
RestoreAndFailCommittableStateManager.initializeState(org.apache.flink.runtime.state.StateInitializationContext context,
Committer committer) |
void |
NoopCommittableStateManager.initializeState(org.apache.flink.runtime.state.StateInitializationContext context,
Committer committer) |
void |
CommittableStateManager.initializeState(org.apache.flink.runtime.state.StateInitializationContext context,
Committer committer) |
Constructor and Description |
---|
CommitterOperator(boolean streamingCheckpointEnabled,
String initialCommitUser,
org.apache.flink.util.function.SerializableFunction<String,Committer> committerFactory,
CommittableStateManager committableStateManager) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.