Package com.linkedin.davinci.ingestion.isolated

Class IsolatedIngestionNotifier

java.lang.Object

com.linkedin.davinci.ingestion.isolated.IsolatedIngestionNotifier

All Implemented Interfaces:

VeniceNotifier, java.io.Closeable, java.lang.AutoCloseable

public class IsolatedIngestionNotifier
extends java.lang.Object
implements VeniceNotifier

Constructor Summary

Constructors

Constructor	Description
IsolatedIngestionNotifier(IsolatedIngestionServer isolatedIngestionServer)

Method Summary

Modifier and Type	Method	Description
void	completed(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
void	dataRecoveryCompleted(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
void	endOfIncrementalPushReceived(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String incrementalPushVersion)
void	endOfPushReceived(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
void	error(java.lang.String kafkaTopic, int partitionId, java.lang.String message, java.lang.Exception e)	Report an error, during the consumption for a Partitions and store.
void	progress(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
void	restarted(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String message)
void	started(java.lang.String kafkaTopic, int partitionId, java.lang.String message)
void	startOfIncrementalPushReceived(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.String incrementalPushVersion)
void	stopped(java.lang.String kafkaTopic, int partitionId, long offset)
void	topicSwitchReceived(java.lang.String kafkaTopic, int partitionId, long offset, java.lang.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, close, completed, completed, endOfIncrementalPushReceived, endOfPushReceived, progress, quotaNotViolated, quotaNotViolated, quotaViolated, quotaViolated, restarted, started, startOfIncrementalPushReceived, topicSwitchReceived

Constructor Detail

IsolatedIngestionNotifier

public IsolatedIngestionNotifier(IsolatedIngestionServer isolatedIngestionServer)

Method Detail

completed

public void completed(java.lang.String kafkaTopic,
                      int partitionId,
                      long offset,
                      java.lang.String message)

Specified by:

completed in interface VeniceNotifier

error

public void error(java.lang.String kafkaTopic,
                  int partitionId,
                  java.lang.String message,
                  java.lang.Exception e)

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

started

public void started(java.lang.String kafkaTopic,
                    int partitionId,
                    java.lang.String message)

Specified by:

started in interface VeniceNotifier

restarted

public void restarted(java.lang.String kafkaTopic,
                      int partitionId,
                      long offset,
                      java.lang.String message)

Specified by:

restarted in interface VeniceNotifier

endOfPushReceived

public void endOfPushReceived(java.lang.String kafkaTopic,
                              int partitionId,
                              long offset,
                              java.lang.String message)

Specified by:

endOfPushReceived in interface VeniceNotifier

startOfIncrementalPushReceived

public void startOfIncrementalPushReceived(java.lang.String kafkaTopic,
                                           int partitionId,
                                           long offset,
                                           java.lang.String incrementalPushVersion)

Specified by:

startOfIncrementalPushReceived in interface VeniceNotifier

endOfIncrementalPushReceived

public void endOfIncrementalPushReceived(java.lang.String kafkaTopic,
                                         int partitionId,
                                         long offset,
                                         java.lang.String incrementalPushVersion)

Specified by:

endOfIncrementalPushReceived in interface VeniceNotifier

topicSwitchReceived

public void topicSwitchReceived(java.lang.String kafkaTopic,
                                int partitionId,
                                long offset,
                                java.lang.String message)

Specified by:

topicSwitchReceived in interface VeniceNotifier

dataRecoveryCompleted

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

Specified by:

dataRecoveryCompleted in interface VeniceNotifier

progress

public void progress(java.lang.String kafkaTopic,
                     int partitionId,
                     long offset,
                     java.lang.String message)

Specified by:

progress in interface VeniceNotifier

stopped

public void stopped(java.lang.String kafkaTopic,
                    int partitionId,
                    long offset)

Specified by:

stopped in interface VeniceNotifier