public class ConsumerProgressCalculator extends Object
Constructor and Description |
---|
ConsumerProgressCalculator(int parallelism) |
Modifier and Type | Method and Description |
---|---|
OptionalLong |
notifyCheckpointComplete(long checkpointId) |
void |
notifySnapshotState(long checkpointId,
Set<Integer> readersAwaitingSplit,
java.util.function.Function<Integer,Long> unassignedCalculationFunction,
int parallelism) |
void |
updateAssignInformation(int subtaskId,
FileStoreSourceSplit split) |
void |
updateConsumeProgress(int subtaskId,
ReaderConsumeProgressEvent event) |
public void updateConsumeProgress(int subtaskId, ReaderConsumeProgressEvent event)
public void updateAssignInformation(int subtaskId, FileStoreSourceSplit split)
public void notifySnapshotState(long checkpointId, Set<Integer> readersAwaitingSplit, java.util.function.Function<Integer,Long> unassignedCalculationFunction, int parallelism)
public OptionalLong notifyCheckpointComplete(long checkpointId)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.