Class RouterBasedPushMonitor

  • All Implemented Interfaces:, java.lang.AutoCloseable

    public class RouterBasedPushMonitor
    extends java.lang.Object
    This push monitor is able to query push job status from routers; it only works for stores running in Leader/Follower mode and it will be built for STREAM_REPROCESSING job.
    • Constructor Detail

      • RouterBasedPushMonitor

        public RouterBasedPushMonitor​(TransportClient d2TransportClient,
                                      java.lang.String resourceName,
                                      VeniceSystemFactory factory,
                                      org.apache.samza.system.SystemProducer producer)
    • Method Detail

      • start

        public void start()
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface
      • setCurrentStatus

        public void setCurrentStatus​(ExecutionStatus currentStatus)
      • setStreamReprocessingExitMode

        public void setStreamReprocessingExitMode​(SamzaExitMode exitMode)