Modifier and Type | Method and Description |
---|---|
ManifestCommittable |
StoreCommitter.combine(long checkpointId,
long watermark,
List<Committable> committables) |
ManifestCommittable |
StoreCommitter.combine(long checkpointId,
long watermark,
ManifestCommittable manifestCommittable,
List<Committable> committables) |
Modifier and Type | Method and Description |
---|---|
protected abstract CommittableStateManager<ManifestCommittable> |
FlinkSink.createCommittableStateManager() |
protected CommittableStateManager<ManifestCommittable> |
UnawareBucketCompactionSink.createCommittableStateManager() |
protected CommittableStateManager<ManifestCommittable> |
CompactorSink.createCommittableStateManager() |
protected CommittableStateManager<ManifestCommittable> |
FlinkWriteSink.createCommittableStateManager() |
protected abstract Committer.Factory<Committable,ManifestCommittable> |
FlinkSink.createCommitterFactory() |
protected Committer.Factory<Committable,ManifestCommittable> |
UnawareBucketCompactionSink.createCommitterFactory() |
protected Committer.Factory<Committable,ManifestCommittable> |
CompactorSink.createCommitterFactory() |
protected Committer.Factory<Committable,ManifestCommittable> |
FlinkWriteSink.createCommitterFactory() |
Modifier and Type | Method and Description |
---|---|
ManifestCommittable |
StoreCommitter.combine(long checkpointId,
long watermark,
ManifestCommittable manifestCommittable,
List<Committable> committables) |
Modifier and Type | Method and Description |
---|---|
void |
StoreCommitter.commit(List<ManifestCommittable> committables) |
int |
StoreCommitter.filterAndCommit(List<ManifestCommittable> globalCommittables,
boolean checkAppendFiles) |
void |
NoopCommittableStateManager.initializeState(org.apache.flink.runtime.state.StateInitializationContext context,
Committer<?,ManifestCommittable> committer) |
void |
NoopCommittableStateManager.snapshotState(org.apache.flink.runtime.state.StateSnapshotContext context,
List<ManifestCommittable> committables) |
Modifier and Type | Method and Description |
---|---|
void |
PartitionListener.notifyCommittable(List<ManifestCommittable> committables) |
void |
PartitionListeners.notifyCommittable(List<ManifestCommittable> committables) |
void |
PartitionMarkDone.notifyCommittable(List<ManifestCommittable> committables) |
void |
ReportHmsListener.notifyCommittable(List<ManifestCommittable> committables) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractIcebergCommitCallback.retry(ManifestCommittable committable) |
Modifier and Type | Method and Description |
---|---|
ManifestCommittable |
WrappedManifestCommittable.computeCommittableIfAbsent(Identifier identifier,
long checkpointId,
long watermark) |
ManifestCommittable |
ManifestCommittableSerializer.deserialize(int version,
byte[] serialized) |
Modifier and Type | Method and Description |
---|---|
Map<Identifier,ManifestCommittable> |
WrappedManifestCommittable.manifestCommittables() |
Modifier and Type | Method and Description |
---|---|
void |
WrappedManifestCommittable.putManifestCommittable(Identifier identifier,
ManifestCommittable manifestCommittable) |
byte[] |
ManifestCommittableSerializer.serialize(ManifestCommittable obj) |
Modifier and Type | Method and Description |
---|---|
void |
TagPreviewCommitCallback.retry(ManifestCommittable committable) |
void |
AddPartitionCommitCallback.retry(ManifestCommittable committable) |
Modifier and Type | Method and Description |
---|---|
List<ManifestCommittable> |
FileStoreCommitImpl.filterCommitted(List<ManifestCommittable> committables) |
List<ManifestCommittable> |
FileStoreCommit.filterCommitted(List<ManifestCommittable> committables)
Find out which committables need to be retried when recovering from the failure.
|
Modifier and Type | Method and Description |
---|---|
void |
FileStoreCommitImpl.commit(ManifestCommittable committable,
Map<String,String> properties) |
void |
FileStoreCommit.commit(ManifestCommittable committable,
Map<String,String> properties)
Commit from manifest committable.
|
void |
FileStoreCommitImpl.commit(ManifestCommittable committable,
Map<String,String> properties,
boolean checkAppendFiles) |
void |
FileStoreCommit.commit(ManifestCommittable committable,
Map<String,String> properties,
boolean checkAppendFiles)
Commit from manifest committable with checkAppendFiles.
|
void |
FileStoreCommitImpl.overwrite(Map<String,String> partition,
ManifestCommittable committable,
Map<String,String> properties) |
void |
FileStoreCommit.overwrite(Map<String,String> partition,
ManifestCommittable committable,
Map<String,String> properties)
Overwrite from manifest committable and partition.
|
Modifier and Type | Method and Description |
---|---|
List<ManifestCommittable> |
FileStoreCommitImpl.filterCommitted(List<ManifestCommittable> committables) |
List<ManifestCommittable> |
FileStoreCommit.filterCommitted(List<ManifestCommittable> committables)
Find out which committables need to be retried when recovering from the failure.
|
Modifier and Type | Method and Description |
---|---|
void |
TableCommitImpl.commit(ManifestCommittable committable) |
void |
CommitCallback.retry(ManifestCommittable committable) |
Modifier and Type | Method and Description |
---|---|
void |
TableCommitImpl.commitMultiple(List<ManifestCommittable> committables,
boolean checkAppendFiles) |
int |
TableCommitImpl.filterAndCommitMultiple(List<ManifestCommittable> committables) |
int |
TableCommitImpl.filterAndCommitMultiple(List<ManifestCommittable> committables,
boolean checkAppendFiles) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.