Package com.linkedin.davinci.notifier

Class PushStatusNotifier

java.lang.Object

com.linkedin.davinci.notifier.PushStatusNotifier

All Implemented Interfaces:

VeniceNotifier, Closeable, AutoCloseable

public class PushStatusNotifier
extends Object
implements VeniceNotifier

Notifies both OfflinePushStatus and Helix Customized View

Constructor Summary

Constructors

Constructor	Description
PushStatusNotifier(OfflinePushAccessor offlinePushAccessor, HelixPartitionStatusAccessor helixPartitionStatusAccessor, PushStatusStoreWriter pushStatusStoreWriter, ReadOnlyStoreRepository storeRepository, String instanceId, VeniceServerConfig.IncrementalPushStatusWriteMode incrementalPushStatusWriteMode)

Method Summary

Modifier and Type	Method	Description
void	batchEndOfIncrementalPushReceived(String topic, int partitionId, long offset, List<String> pendingReportIncPushVersionList)
void	close()	The Process is shutting down and clean up the resources associated with the Notifier.
void	completed(String topic, int partitionId, long offset, String message)
void	dataRecoveryCompleted(String kafkaTopic, int partitionId, long offset, String message)
void	endOfIncrementalPushReceived(String topic, int partitionId, long offset, String message)
void	endOfPushReceived(String topic, int partitionId, long offset, String message)
void	error(String topic, int partitionId, String message, Exception ex)	Report an error, during the consumption for a Partitions and store.
void	progress(String topic, int partitionId, long offset, String message)
void	quotaNotViolated(String topic, int partitionId, long offset, String message)
void	quotaViolated(String topic, int partitionId, long offset, String message)
void	restarted(String topic, int partitionId, long offset, String message)
void	started(String topic, int partitionId, String message)
void	startOfIncrementalPushReceived(String topic, int partitionId, long offset, String message)
void	topicSwitchReceived(String topic, int partitionId, long offset, String message)

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

catchUpVersionTopicOffsetLag, completed, endOfIncrementalPushReceived, endOfPushReceived, progress, quotaNotViolated, quotaViolated, restarted, started, startOfIncrementalPushReceived, stopped, topicSwitchReceived

Constructor Details

PushStatusNotifier

public PushStatusNotifier(OfflinePushAccessor offlinePushAccessor,
 HelixPartitionStatusAccessor helixPartitionStatusAccessor,
 PushStatusStoreWriter pushStatusStoreWriter,
 ReadOnlyStoreRepository storeRepository,
 String instanceId,
 VeniceServerConfig.IncrementalPushStatusWriteMode incrementalPushStatusWriteMode)

Method Details

started

public void started(String topic,
 int partitionId,
 String message)

Specified by:

started in interface VeniceNotifier

restarted

public void restarted(String topic,
 int partitionId,
 long offset,
 String message)

Specified by:

restarted in interface VeniceNotifier

completed

public void completed(String topic,
 int partitionId,
 long offset,
 String message)

Specified by:

completed in interface VeniceNotifier

quotaViolated

public void quotaViolated(String topic,
 int partitionId,
 long offset,
 String message)

Specified by:

quotaViolated in interface VeniceNotifier

quotaNotViolated

public void quotaNotViolated(String topic,
 int partitionId,
 long offset,
 String message)

Specified by:

quotaNotViolated in interface VeniceNotifier

progress

public void progress(String topic,
 int partitionId,
 long offset,
 String message)

Specified by:

progress in interface VeniceNotifier

endOfPushReceived

public void endOfPushReceived(String topic,
 int partitionId,
 long offset,
 String message)

Specified by:

endOfPushReceived in interface VeniceNotifier

topicSwitchReceived

public void topicSwitchReceived(String topic,
 int partitionId,
 long offset,
 String message)

Specified by:

topicSwitchReceived in interface VeniceNotifier

dataRecoveryCompleted

public void dataRecoveryCompleted(String kafkaTopic,
 int partitionId,
 long offset,
 String message)

Specified by:

dataRecoveryCompleted in interface VeniceNotifier

startOfIncrementalPushReceived

public void startOfIncrementalPushReceived(String topic,
 int partitionId,
 long offset,
 String message)

Specified by:

startOfIncrementalPushReceived in interface VeniceNotifier

endOfIncrementalPushReceived

public void endOfIncrementalPushReceived(String topic,
 int partitionId,
 long offset,
 String message)

Specified by:

endOfIncrementalPushReceived in interface VeniceNotifier

batchEndOfIncrementalPushReceived

public void batchEndOfIncrementalPushReceived(String topic,
 int partitionId,
 long offset,
 List<String> pendingReportIncPushVersionList)

Specified by:

batchEndOfIncrementalPushReceived in interface VeniceNotifier

close

public void close()

Description copied from interface: VeniceNotifier

The Process is shutting down and clean up the resources associated with the Notifier. N.B. When implementing the method, make it idempotent.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface VeniceNotifier

error

public void error(String topic,
 int partitionId,
 String message,
 Exception ex)

Description copied from interface: VeniceNotifier

Report an error, during the consumption for a Partitions and store. The error may or may not be fatal.

Specified by:

error in interface VeniceNotifier