public interface Committer extends AutoCloseable
Committer
is responsible for creating and committing an aggregated committable, which
we call committable (see combine(long, java.util.List<org.apache.flink.table.store.connector.sink.Committable>)
).
The Committer
runs with parallelism equal to 1.
Modifier and Type | Method and Description |
---|---|
ManifestCommittable |
combine(long checkpointId,
List<Committable> committables)
Compute an aggregated committable from a list of committables.
|
void |
commit(List<ManifestCommittable> globalCommittables)
Commits the given
ManifestCommittable . |
List<ManifestCommittable> |
filterRecoveredCommittables(List<ManifestCommittable> globalCommittables)
Find out which global committables need to be retried when recovering from the failure.
|
close
List<ManifestCommittable> filterRecoveredCommittables(List<ManifestCommittable> globalCommittables) throws IOException
IOException
ManifestCommittable combine(long checkpointId, List<Committable> committables) throws IOException
IOException
void commit(List<ManifestCommittable> globalCommittables) throws IOException, InterruptedException
ManifestCommittable
.IOException
InterruptedException
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.