Modifier and Type | Field and Description |
---|---|
protected NavigableMap<Long,ManifestCommittable> |
CommitterOperator.committablesPerCheckpoint
Group the committable by the checkpoint id.
|
Modifier and Type | Method and Description |
---|---|
ManifestCommittable |
Committer.combine(long checkpointId,
List<Committable> committables)
Compute an aggregated committable from a list of committables.
|
ManifestCommittable |
StoreCommitter.combine(long checkpointId,
List<Committable> committables) |
Modifier and Type | Method and Description |
---|---|
List<ManifestCommittable> |
Committer.filterRecoveredCommittables(List<ManifestCommittable> globalCommittables)
Find out which global committables need to be retried when recovering from the failure.
|
List<ManifestCommittable> |
StoreCommitter.filterRecoveredCommittables(List<ManifestCommittable> globalCommittables) |
Modifier and Type | Method and Description |
---|---|
void |
Committer.commit(List<ManifestCommittable> globalCommittables)
Commits the given
ManifestCommittable . |
void |
StoreCommitter.commit(List<ManifestCommittable> committables) |
List<ManifestCommittable> |
Committer.filterRecoveredCommittables(List<ManifestCommittable> globalCommittables)
Find out which global committables need to be retried when recovering from the failure.
|
List<ManifestCommittable> |
StoreCommitter.filterRecoveredCommittables(List<ManifestCommittable> globalCommittables) |
void |
RestoreAndFailCommittableStateManager.snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context,
List<ManifestCommittable> committables) |
void |
NoopCommittableStateManager.snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context,
List<ManifestCommittable> committables) |
void |
CommittableStateManager.snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context,
List<ManifestCommittable> committables) |
Constructor and Description |
---|
RestoreAndFailCommittableStateManager(org.apache.flink.util.function.SerializableSupplier<org.apache.flink.core.io.SimpleVersionedSerializer<ManifestCommittable>> committableSerializer) |
Modifier and Type | Method and Description |
---|---|
ManifestCommittable |
ManifestCommittableSerializer.deserialize(int version,
byte[] serialized) |
Modifier and Type | Method and Description |
---|---|
byte[] |
ManifestCommittableSerializer.serialize(ManifestCommittable obj) |
Modifier and Type | Method and Description |
---|---|
List<ManifestCommittable> |
FileStoreCommit.filterCommitted(List<ManifestCommittable> committableList)
Find out which manifest committable need to be retried when recovering from the failure.
|
List<ManifestCommittable> |
FileStoreCommitImpl.filterCommitted(List<ManifestCommittable> committableList) |
Modifier and Type | Method and Description |
---|---|
void |
FileStoreCommit.commit(ManifestCommittable committable,
Map<String,String> properties)
Commit from manifest committable.
|
void |
FileStoreCommitImpl.commit(ManifestCommittable committable,
Map<String,String> properties) |
void |
FileStoreCommit.overwrite(List<Map<String,String>> partitions,
ManifestCommittable committable,
Map<String,String> properties)
Overwrite multiple partitions from manifest committable.
|
void |
FileStoreCommitImpl.overwrite(List<Map<String,String>> partitions,
ManifestCommittable committable,
Map<String,String> properties) |
default void |
FileStoreCommit.overwrite(Map<String,String> partition,
ManifestCommittable committable,
Map<String,String> properties)
Overwrite a single partition from manifest committable.
|
Modifier and Type | Method and Description |
---|---|
List<ManifestCommittable> |
FileStoreCommit.filterCommitted(List<ManifestCommittable> committableList)
Find out which manifest committable need to be retried when recovering from the failure.
|
List<ManifestCommittable> |
FileStoreCommitImpl.filterCommitted(List<ManifestCommittable> committableList) |
Modifier and Type | Method and Description |
---|---|
List<ManifestCommittable> |
TableCommit.filterCommitted(List<ManifestCommittable> committables) |
Modifier and Type | Method and Description |
---|---|
void |
TableCommit.commit(List<ManifestCommittable> committables) |
List<ManifestCommittable> |
TableCommit.filterCommitted(List<ManifestCommittable> committables) |
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.