Class StateModelIngestionProgressNotifier

  • All Implemented Interfaces:
    VeniceNotifier,, java.lang.AutoCloseable
    Direct Known Subclasses:

    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 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