blob: a2fa44170a406f1afe71520515cdf880abeb8091 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
|
class ProcessorTopology(object):
def __init__(self, processor_nodes, source_by_topics, state_store_suppliers):
self.processor_nodes = processor_nodes
self.source_by_topics = source_by_topics
self.state_store_suppliers = state_store_suppliers
def sourceTopics(self):
return set(self.source_by_topics)
def source(self, topic):
return self.source_by_topics.get(topic)
def sources(self):
return set(self.source_by_topics.values())
def processors(self):
return self.processor_nodes
def state_store_suppliers(self):
return self.state_store_suppliers
|
