org.apache.paimon.flink.source

Class ConsumerProgressCalculator

java.lang.Object

org.apache.paimon.flink.source.ConsumerProgressCalculator

public class ConsumerProgressCalculator
extends Object

Calculator for calculating consumer consumption progress.

Constructor Summary

Constructors

Constructor and Description
ConsumerProgressCalculator(int parallelism)

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConsumerProgressCalculator

public ConsumerProgressCalculator(int parallelism)

Method Detail

updateConsumeProgress

public void updateConsumeProgress(int subtaskId,
                                  ReaderConsumeProgressEvent event)

updateAssignInformation

public void updateAssignInformation(int subtaskId,
                                    FileStoreSourceSplit split)

notifySnapshotState

public void notifySnapshotState(long checkpointId,
                                Set<Integer> readersAwaitingSplit,
                                java.util.function.Function<Integer,Long> unassignedCalculationFunction,
                                int parallelism)

notifyCheckpointComplete

public OptionalLong notifyCheckpointComplete(long checkpointId)