Package com.linkedin.venice.ingestion.control

Class MultiRegionRealTimeTopicSwitcher

java.lang.Object

com.linkedin.venice.ingestion.control.RealTimeTopicSwitcher

com.linkedin.venice.ingestion.control.MultiRegionRealTimeTopicSwitcher

public class MultiRegionRealTimeTopicSwitcher
extends RealTimeTopicSwitcher

Field Summary

Fields inherited from class com.linkedin.venice.ingestion.control.RealTimeTopicSwitcher

veniceWriterFactory

Constructor Summary

Constructors

Constructor	Description
MultiRegionRealTimeTopicSwitcher(TopicManager topicManager, VeniceWriterFactory localVeniceWriterFactory, VeniceProperties veniceProperties, PubSubTopicRepository pubSubTopicRepository, Map<String,String> activeActiveRealTimeSourceFabricBrokerUrlMap, String localDataCenterName)

Method Summary

Modifier and Type	Method	Description
protected void	broadcastVersionSwap(Version previousStoreVersion, Version nextStoreVersion, String topicName)

Methods inherited from class com.linkedin.venice.ingestion.control.RealTimeTopicSwitcher

switchToRealTimeTopic, transmitVersionSwapMessage

Methods inherited from class java.lang.Object

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

Constructor Details

MultiRegionRealTimeTopicSwitcher

public MultiRegionRealTimeTopicSwitcher(TopicManager topicManager,
 VeniceWriterFactory localVeniceWriterFactory,
 VeniceProperties veniceProperties,
 PubSubTopicRepository pubSubTopicRepository,
 Map<String,String> activeActiveRealTimeSourceFabricBrokerUrlMap,
 String localDataCenterName)

Method Details

broadcastVersionSwap

protected void broadcastVersionSwap(Version previousStoreVersion,
 Version nextStoreVersion,
 String topicName)

Overrides:

broadcastVersionSwap in class RealTimeTopicSwitcher