Package com.linkedin.davinci.kafka.consumer

Class TopicSwitchWrapper

java.lang.Object

com.linkedin.davinci.kafka.consumer.TopicSwitchWrapper

public class TopicSwitchWrapper
extends Object

This class precomputes the conversion from Avro's CharSequence to String, and also hangs on to the correct instance of PubSubTopic, so that the lookup need not be performed in many locations.

Constructor Summary

Constructors

Constructor	Description
TopicSwitchWrapper(TopicSwitch topicSwitch, PubSubTopic newSourceTopic)

Method Summary

Modifier and Type	Method	Description
PubSubTopic	getNewSourceTopic()
Set<String>	getSourceServers()
TopicSwitch	getTopicSwitch()

Methods inherited from class java.lang.Object

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

Constructor Details

TopicSwitchWrapper

public TopicSwitchWrapper(TopicSwitch topicSwitch,
 PubSubTopic newSourceTopic)

Method Details

getTopicSwitch

public TopicSwitch getTopicSwitch()

getNewSourceTopic

public PubSubTopic getNewSourceTopic()

getSourceServers

public Set<String> getSourceServers()