Package com.linkedin.davinci.helix
Class LeaderFollowerIngestionProgressNotifier
- java.lang.Object
-
- com.linkedin.davinci.helix.StateModelIngestionProgressNotifier
-
- com.linkedin.davinci.helix.LeaderFollowerIngestionProgressNotifier
-
- All Implemented Interfaces:
VeniceNotifier
,java.io.Closeable
,java.lang.AutoCloseable
public class LeaderFollowerIngestionProgressNotifier extends StateModelIngestionProgressNotifier
This class used to overrideVeniceNotifier.catchUpVersionTopicOffsetLag(String, int)
to release the latch when the resource is the current version. We remove the logic due to a potential race condition between latch being released and push being completed. As for now, it's a placeholder for any future modification for L/F state model. TODO: remove the class when every store is running in L/F model!
-
-
Constructor Summary
Constructors Constructor Description LeaderFollowerIngestionProgressNotifier()
-
Method Summary
-
Methods inherited from class com.linkedin.davinci.helix.StateModelIngestionProgressNotifier
completed, error, stopped
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface com.linkedin.davinci.notifier.VeniceNotifier
batchEndOfIncrementalPushReceived, catchUpVersionTopicOffsetLag, close, completed, dataRecoveryCompleted, endOfIncrementalPushReceived, endOfIncrementalPushReceived, endOfPushReceived, endOfPushReceived, progress, progress, quotaNotViolated, quotaNotViolated, quotaViolated, quotaViolated, restarted, restarted, started, started, startOfIncrementalPushReceived, startOfIncrementalPushReceived, topicSwitchReceived, topicSwitchReceived
-
-