Package com.linkedin.davinci.helix

Class LeaderFollowerIngestionProgressNotifier

java.lang.Object

com.linkedin.davinci.helix.StateModelIngestionProgressNotifier

com.linkedin.davinci.helix.LeaderFollowerIngestionProgressNotifier

All Implemented Interfaces:

VeniceNotifier, Closeable, AutoCloseable

public class LeaderFollowerIngestionProgressNotifier
extends StateModelIngestionProgressNotifier

This class used to override VeniceNotifier.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

Constructor Details

LeaderFollowerIngestionProgressNotifier

public LeaderFollowerIngestionProgressNotifier()