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, java.util.Optional<java.lang.String> incrementalPushVersion)
void	batchPushEndSignalSent()
void	batchPushStartSignalSent()
java.util.Set<java.lang.Integer>	getTrackedPartitions(java.util.Optional<java.lang.String> incrementalPushVersion)
boolean	isAnyPartitionOnErrorStatus(java.util.Optional<java.lang.String> incrementalPushVersion)
boolean	isBatchPushEndSignalSent()
boolean	isBatchPushStartSignalSent()
void	shutdown()
void	start()
void	updatePartitionStatus(int partition, ExecutionStatus status, java.util.Optional<java.lang.String> incrementalPushVersion)

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,
                                  java.util.Optional<java.lang.String> incrementalPushVersion)

getTrackedPartitions

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

areAllPartitionsOnSameTerminalStatus

public boolean areAllPartitionsOnSameTerminalStatus(ExecutionStatus status,
                                                    java.util.Optional<java.lang.String> incrementalPushVersion)

isAnyPartitionOnErrorStatus

public boolean isAnyPartitionOnErrorStatus(java.util.Optional<java.lang.String> incrementalPushVersion)

start

public void start()

shutdown

public void shutdown()