Package com.linkedin.venice.ingestion.control

Class RealTimeTopicSwitcher

java.lang.Object

com.linkedin.venice.ingestion.control.RealTimeTopicSwitcher

public class RealTimeTopicSwitcher
extends java.lang.Object

Class which implements the process of switching from a batch topic (e.g. version-topic or stream reprocessing topic) to a real-time topic, including: 1. Ensuring the pre-conditions are met, 2. Determining the start timestamp to rewind to, 3. Writing the actual TopicSwitch control message.

Constructor Summary

Constructors

Constructor	Description
RealTimeTopicSwitcher(TopicManager topicManager, VeniceWriterFactory veniceWriterFactory, VeniceProperties veniceProperties, PubSubTopicRepository pubSubTopicRepository)

Method Summary

Modifier and Type	Method	Description
boolean	hasViewConfigs(Version nextStoreVersion, Version previousStoreVersion)
void	switchToRealTimeTopic(java.lang.String realTimeTopicName, java.lang.String topicNameWhereToSendTheTopicSwitch, Store store, java.lang.String aggregateRealTimeSourceKafkaUrl, java.util.List<java.lang.String> activeActiveRealTimeSourceKafkaURLs)
void	transmitVersionSwapMessage(Store store, int previousVersion, int nextVersion)

Methods inherited from class java.lang.Object

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

Constructor Detail

RealTimeTopicSwitcher

public RealTimeTopicSwitcher(TopicManager topicManager,
                             VeniceWriterFactory veniceWriterFactory,
                             VeniceProperties veniceProperties,
                             PubSubTopicRepository pubSubTopicRepository)

Method Detail

transmitVersionSwapMessage

public void transmitVersionSwapMessage(Store store,
                                       int previousVersion,
                                       int nextVersion)

hasViewConfigs

public boolean hasViewConfigs(Version nextStoreVersion,
                              Version previousStoreVersion)

switchToRealTimeTopic

public void switchToRealTimeTopic(java.lang.String realTimeTopicName,
                                  java.lang.String topicNameWhereToSendTheTopicSwitch,
                                  Store store,
                                  java.lang.String aggregateRealTimeSourceKafkaUrl,
                                  java.util.List<java.lang.String> activeActiveRealTimeSourceKafkaURLs)