Package com.linkedin.venice.pushmonitor

Class RouterBasedPushMonitor

java.lang.Object

com.linkedin.venice.pushmonitor.RouterBasedPushMonitor

All Implemented Interfaces:

Closeable, AutoCloseable

public class RouterBasedPushMonitor
extends Object
implements Closeable

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 Summary

Constructors

Constructor	Description
RouterBasedPushMonitor(TransportClient d2TransportClient, String resourceName, VeniceSystemFactory factory, org.apache.samza.system.SystemProducer producer)

Method Summary

Modifier and Type	Method	Description
void	close()
ExecutionStatus	getCurrentStatus()
void	setCurrentStatus(ExecutionStatus currentStatus)
void	setStreamReprocessingExitMode(SamzaExitMode exitMode)
void	start()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RouterBasedPushMonitor

public RouterBasedPushMonitor(TransportClient d2TransportClient,
 String resourceName,
 VeniceSystemFactory factory,
 org.apache.samza.system.SystemProducer producer)

Method Details

start

public void start()

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

setCurrentStatus

public void setCurrentStatus(ExecutionStatus currentStatus)

getCurrentStatus

public ExecutionStatus getCurrentStatus()

setStreamReprocessingExitMode

public void setStreamReprocessingExitMode(SamzaExitMode exitMode)