Package com.linkedin.davinci.helix

Class StateModelIngestionProgressNotifier

java.lang.Object

com.linkedin.davinci.helix.StateModelIngestionProgressNotifier

All Implemented Interfaces:

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

Direct Known Subclasses:

LeaderFollowerIngestionProgressNotifier

public class StateModelIngestionProgressNotifier
extends java.lang.Object
implements VeniceNotifier

This class notifies the Helix State Models (SM) about corresponding ingestion progress. The class also holds latches that can be used in SM in the cases when state transitions need to coordinate with ingestion progress.

Constructor Summary

Constructors

Constructor	Description
StateModelIngestionProgressNotifier()

Method Summary

Modifier and Type	Method	Description
void	completed(java.lang.String resourceName, int partitionId, long offset, java.lang.String message)
void	error(java.lang.String resourceName, int partitionId, java.lang.String message, java.lang.Exception ex)	Report an error, during the consumption for a Partitions and store.
void	stopped(java.lang.String resourceName, int partitionId, long offset)

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, dataRecoveryCompleted, endOfIncrementalPushReceived, endOfIncrementalPushReceived, endOfPushReceived, endOfPushReceived, progress, progress, quotaNotViolated, quotaNotViolated, quotaViolated, quotaViolated, restarted, restarted, started, started, startOfIncrementalPushReceived, startOfIncrementalPushReceived, topicSwitchReceived, topicSwitchReceived

Constructor Detail

StateModelIngestionProgressNotifier

public StateModelIngestionProgressNotifier()

Method Detail

completed

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

Specified by:

completed in interface VeniceNotifier

error

public void error(java.lang.String resourceName,
                  int partitionId,
                  java.lang.String message,
                  java.lang.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

stopped

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

Specified by:

stopped in interface VeniceNotifier