Class IsolatedIngestionNotifier
java.lang.Object
com.linkedin.davinci.ingestion.isolated.IsolatedIngestionNotifier
- All Implemented Interfaces:
VeniceNotifier
,Closeable
,AutoCloseable
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
completed
(String kafkaTopic, int partitionId, PubSubPosition position, String message) void
dataRecoveryCompleted
(String kafkaTopic, int partitionId, PubSubPosition position, String message) void
endOfIncrementalPushReceived
(String kafkaTopic, int partitionId, PubSubPosition position, String incrementalPushVersion) void
endOfPushReceived
(String kafkaTopic, int partitionId, PubSubPosition position, String message) void
Report an error, during the consumption for a Partitions and store.void
progress
(String kafkaTopic, int partitionId, PubSubPosition position, String message) void
restarted
(String kafkaTopic, int partitionId, PubSubPosition position, String message) void
void
startOfIncrementalPushReceived
(String kafkaTopic, int partitionId, PubSubPosition position, String incrementalPushVersion) void
stopped
(String kafkaTopic, int partitionId, PubSubPosition position) void
topicSwitchReceived
(String kafkaTopic, int partitionId, PubSubPosition position, 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
batchEndOfIncrementalPushReceived, catchUpVersionTopicOffsetLag, close, completed, endOfIncrementalPushReceived, endOfPushReceived, progress, quotaNotViolated, quotaNotViolated, quotaViolated, quotaViolated, restarted, started, startOfIncrementalPushReceived, topicSwitchReceived
-
Constructor Details
-
IsolatedIngestionNotifier
-
-
Method Details
-
completed
- Specified by:
completed
in interfaceVeniceNotifier
-
error
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 interfaceVeniceNotifier
-
started
- Specified by:
started
in interfaceVeniceNotifier
-
restarted
- Specified by:
restarted
in interfaceVeniceNotifier
-
endOfPushReceived
public void endOfPushReceived(String kafkaTopic, int partitionId, PubSubPosition position, String message) - Specified by:
endOfPushReceived
in interfaceVeniceNotifier
-
startOfIncrementalPushReceived
public void startOfIncrementalPushReceived(String kafkaTopic, int partitionId, PubSubPosition position, String incrementalPushVersion) - Specified by:
startOfIncrementalPushReceived
in interfaceVeniceNotifier
-
endOfIncrementalPushReceived
public void endOfIncrementalPushReceived(String kafkaTopic, int partitionId, PubSubPosition position, String incrementalPushVersion) - Specified by:
endOfIncrementalPushReceived
in interfaceVeniceNotifier
-
topicSwitchReceived
public void topicSwitchReceived(String kafkaTopic, int partitionId, PubSubPosition position, String message) - Specified by:
topicSwitchReceived
in interfaceVeniceNotifier
-
dataRecoveryCompleted
public void dataRecoveryCompleted(String kafkaTopic, int partitionId, PubSubPosition position, String message) - Specified by:
dataRecoveryCompleted
in interfaceVeniceNotifier
-
progress
- Specified by:
progress
in interfaceVeniceNotifier
-
stopped
- Specified by:
stopped
in interfaceVeniceNotifier
-