Package com.linkedin.davinci.notifier

Class DaVinciPushStatusUpdateTask

java.lang.Object
com.linkedin.davinci.notifier.DaVinciPushStatusUpdateTask
public class DaVinciPushStatusUpdateTask extends Object
This is a scheduler for sending batching push status in DaVinci.

  • Constructor Details

    • DaVinciPushStatusUpdateTask

      public DaVinciPushStatusUpdateTask(Version version, long daVinciPushStatusCheckIntervalInMs, PushStatusStoreWriter pushStatusStoreWriter, Supplier<Boolean> areAllPartitionFuturesCompletedSuccessfully)

  • Method Details

    • isBatchPushStartSignalSent

      public boolean isBatchPushStartSignalSent()

    • isBatchPushEndSignalSent

      public boolean isBatchPushEndSignalSent()

    • batchPushStartSignalSent

      public void batchPushStartSignalSent()

    • batchPushEndSignalSent

      public void batchPushEndSignalSent()

    • updatePartitionStatus

      public void updatePartitionStatus(int partition, ExecutionStatus status, Optional<String> incrementalPushVersion)

    • getTrackedPartitions

      public Set<Integer> getTrackedPartitions(Optional<String> incrementalPushVersion)

    • areAllPartitionsOnSameTerminalStatus

      public boolean areAllPartitionsOnSameTerminalStatus(ExecutionStatus status, Optional<String> incrementalPushVersion)

    • isAnyPartitionOnErrorStatus

      public boolean isAnyPartitionOnErrorStatus(Optional<String> incrementalPushVersion)

    • start

      public void start()

    • shutdown

      public void shutdown()