Package com.linkedin.venice.pushmonitor

Class PartitionStatusBasedPushMonitor

java.lang.Object

com.linkedin.venice.pushmonitor.AbstractPushMonitor

com.linkedin.venice.pushmonitor.PartitionStatusBasedPushMonitor

All Implemented Interfaces:

RoutingDataRepository.RoutingDataChangedListener, PartitionStatusListener, PushMonitor

public class PartitionStatusBasedPushMonitor
extends AbstractPushMonitor

An implementation of AbstractPushMonitor that listens to ZK PartitionStatus to determine the push status.

Field Summary

Fields inherited from class com.linkedin.venice.pushmonitor.AbstractPushMonitor

MAX_PUSH_TO_KEEP

Constructor Summary

Constructors

Constructor

Description

PartitionStatusBasedPushMonitor(String clusterName, OfflinePushAccessor offlinePushAccessor, StoreCleaner storeCleaner, ReadWriteStoreRepository metadataRepository, RoutingDataRepository routingDataRepository, AggPushHealthStats aggPushHealthStats, RealTimeTopicSwitcher realTimeTopicSwitcher, ClusterLockManager clusterLockManager, String aggregateRealTimeSourceKafkaUrl, List<String> activeActiveRealTimeSourceKafkaURLs, HelixAdminClient helixAdminClient, VeniceControllerClusterConfig controllerConfig, PushStatusStoreReader pushStatusStoreReader, DisabledPartitionStats disabledPartitionStats, VeniceWriterFactory veniceWriterFactory)

Method Summary

Modifier and Type	Method	Description
protected ExecutionStatusWithDetails	checkPushStatus(OfflinePushStatus pushStatus, PartitionAssignment partitionAssignment, DisableReplicaCallback callback)	Checking push status based on Venice offlinePush status
List<Instance>	getReadyToServeInstances(PartitionAssignment partitionAssignment, int partitionId)
void	onPartitionStatusChange(OfflinePushStatus offlinePushStatus)

Methods inherited from class com.linkedin.venice.pushmonitor.AbstractPushMonitor

checkWhetherToStartEOPProcedures, cleanupStoreStatus, getDisableReplicaCallback, getDurationInSec, getIncrementalPushStatusAndDetails, getIncrementalPushStatusFromPushStatusStore, getOfflinePush, getOfflinePushAccessor, getOfflinePushOrThrow, getOfflinePushStatusForStore, getOngoingIncrementalPushVersions, getOngoingIncrementalPushVersions, getPushStatus, getPushStatusAndDetails, getReadWriteStoreRepository, getRealTimeTopicSwitcher, getRoutingDataRepository, getTopicsOfOngoingOfflinePushes, getUncompletedPartitions, handleCompletedPush, handleErrorPush, handleTerminalOfflinePushUpdate, isOfflinePushMonitorDaVinciPushStatusEnabled, loadAllPushes, markOfflinePushAsError, onCustomizedViewAdded, onCustomizedViewChange, onExternalViewChange, onPartitionStatusChange, onRoutingDataDeleted, recordPushPreparationDuration, refreshAndUpdatePushStatus, retireOldErrorPushes, setRealTimeTopicSwitcher, startMonitorOfflinePush, stopAllMonitoring, stopMonitorOfflinePush, updateOfflinePush, updatePushStatus

Methods inherited from class java.lang.Object

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

Constructor Details

PartitionStatusBasedPushMonitor

public PartitionStatusBasedPushMonitor(String clusterName,
 OfflinePushAccessor offlinePushAccessor,
 StoreCleaner storeCleaner,
 ReadWriteStoreRepository metadataRepository,
 RoutingDataRepository routingDataRepository,
 AggPushHealthStats aggPushHealthStats,
 RealTimeTopicSwitcher realTimeTopicSwitcher,
 ClusterLockManager clusterLockManager,
 String aggregateRealTimeSourceKafkaUrl,
 List<String> activeActiveRealTimeSourceKafkaURLs,
 HelixAdminClient helixAdminClient,
 VeniceControllerClusterConfig controllerConfig,
 PushStatusStoreReader pushStatusStoreReader,
 DisabledPartitionStats disabledPartitionStats,
 VeniceWriterFactory veniceWriterFactory)

Method Details

onPartitionStatusChange

public void onPartitionStatusChange(OfflinePushStatus offlinePushStatus)

Overrides:

onPartitionStatusChange in class AbstractPushMonitor

checkPushStatus

protected ExecutionStatusWithDetails checkPushStatus(OfflinePushStatus pushStatus,
 PartitionAssignment partitionAssignment,
 DisableReplicaCallback callback)

Checking push status based on Venice offlinePush status

Specified by:

checkPushStatus in class AbstractPushMonitor

getReadyToServeInstances

public List<Instance> getReadyToServeInstances(PartitionAssignment partitionAssignment,
 int partitionId)

Specified by:

getReadyToServeInstances in interface PushMonitor

Specified by:

getReadyToServeInstances in class AbstractPushMonitor