Package com.linkedin.venice.helix

Class HelixCustomizedViewOfflinePushRepository

java.lang.Object

com.linkedin.venice.helix.HelixBaseRoutingRepository

com.linkedin.venice.helix.HelixCustomizedViewOfflinePushRepository

All Implemented Interfaces:

OnlineInstanceFinder, RoutingDataRepository, VeniceResource, org.apache.helix.api.listeners.ControllerChangeListener, org.apache.helix.api.listeners.RoutingTableChangeListener

public class HelixCustomizedViewOfflinePushRepository
extends HelixBaseRoutingRepository

Extend HelixBaseRoutingRepository to leverage customized view data for offline push.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	HelixCustomizedViewOfflinePushRepository.StoreChangeListener

Nested classes/interfaces inherited from interface com.linkedin.venice.meta.RoutingDataRepository

RoutingDataRepository.RoutingDataChangedListener

Field Summary

Fields inherited from class com.linkedin.venice.helix.HelixBaseRoutingRepository

dataSource, keyBuilder, listenerManager, liveInstancesMap, liveInstancesMapLock, manager, resourceAssignment

Constructor Summary

Constructors

Constructor	Description
HelixCustomizedViewOfflinePushRepository(SafeHelixManager manager, ReadOnlyStoreRepository storeRepository, boolean enableReplicaStatusHistory)

Method Summary

Modifier and Type	Method	Description
void	clear()
Map<Integer,Integer>	getCompletedStatusReplicas(String kafkaTopic, int numberOfPartitions)
List<ReplicaState>	getReplicaStates(String kafkaTopic, int partitionId)
protected void	onCustomizedViewDataChange(org.apache.helix.spectator.RoutingTableSnapshot routingTableSnapshot)
protected void	onExternalViewDataChange(org.apache.helix.spectator.RoutingTableSnapshot routingTableSnapshot)

Methods inherited from class com.linkedin.venice.helix.HelixBaseRoutingRepository

containsKafkaTopic, convertLiveInstances, doesResourcesExistInIdealState, getAllInstances, getLeaderController, getLeaderControllerChangeTimeMs, getLeaderInstance, getNumberOfPartitions, getPartitionAssignments, getReadyToServeInstances, getReadyToServeInstances, getResourceAssignment, getWorkingInstances, isLiveInstance, onControllerChange, onRoutingTableChange, refresh, subscribeRoutingDataChange, unSubscribeRoutingDataChange

Methods inherited from class java.lang.Object

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

Constructor Details

HelixCustomizedViewOfflinePushRepository

public HelixCustomizedViewOfflinePushRepository(SafeHelixManager manager,
 ReadOnlyStoreRepository storeRepository,
 boolean enableReplicaStatusHistory)

Method Details

getReplicaStates

public List<ReplicaState> getReplicaStates(String kafkaTopic,
 int partitionId)

getCompletedStatusReplicas

public Map<Integer,Integer> getCompletedStatusReplicas(String kafkaTopic,
 int numberOfPartitions)

onExternalViewDataChange

protected void onExternalViewDataChange(org.apache.helix.spectator.RoutingTableSnapshot routingTableSnapshot)

Specified by:

onExternalViewDataChange in class HelixBaseRoutingRepository

clear

public void clear()

Specified by:

clear in interface VeniceResource

Overrides:

clear in class HelixBaseRoutingRepository

onCustomizedViewDataChange

protected void onCustomizedViewDataChange(org.apache.helix.spectator.RoutingTableSnapshot routingTableSnapshot)

Specified by:

onCustomizedViewDataChange in class HelixBaseRoutingRepository