Package com.linkedin.davinci.notifier

Class DaVinciPushStatusUpdateTask

java.lang.Object

com.linkedin.davinci.notifier.DaVinciPushStatusUpdateTask

public class DaVinciPushStatusUpdateTask
extends java.lang.Object

This is a scheduler for sending batching push status in DaVinci.

Constructor Summary

Constructors

Constructor	Description
DaVinciPushStatusUpdateTask(Version version, long daVinciPushStatusCheckIntervalInMs, PushStatusStoreWriter pushStatusStoreWriter, java.util.function.Supplier<java.lang.Boolean> areAllPartitionFuturesCompletedSuccessfully)

Method Summary

Modifier and Type	Method	Description
boolean	areAllPartitionsOnSameTerminalStatus(ExecutionStatus status)
void	batchPushEndSignalSent()
void	batchPushStartSignalSent()
java.util.Set<java.lang.Integer>	getTrackedPartitions()	Get the partition id set that is being tracked
boolean	isAnyPartitionOnErrorStatus()
boolean	isBatchPushEndSignalSent()
boolean	isBatchPushStartSignalSent()
void	shutdown()
void	start()
void	updatePartitionStatus(int partition, ExecutionStatus status)

Methods inherited from class java.lang.Object

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

Constructor Detail

DaVinciPushStatusUpdateTask

public DaVinciPushStatusUpdateTask(Version version,
                                   long daVinciPushStatusCheckIntervalInMs,
                                   PushStatusStoreWriter pushStatusStoreWriter,
                                   java.util.function.Supplier<java.lang.Boolean> areAllPartitionFuturesCompletedSuccessfully)

Method Detail

isBatchPushStartSignalSent

public boolean isBatchPushStartSignalSent()

isBatchPushEndSignalSent

public boolean isBatchPushEndSignalSent()

batchPushStartSignalSent

public void batchPushStartSignalSent()

batchPushEndSignalSent

public void batchPushEndSignalSent()

updatePartitionStatus

public void updatePartitionStatus(int partition,
                                  ExecutionStatus status)

getTrackedPartitions

public java.util.Set<java.lang.Integer> getTrackedPartitions()

Get the partition id set that is being tracked

areAllPartitionsOnSameTerminalStatus

public boolean areAllPartitionsOnSameTerminalStatus(ExecutionStatus status)

isAnyPartitionOnErrorStatus

public boolean isAnyPartitionOnErrorStatus()

start

public void start()

shutdown

public void shutdown()