public class GlobalStoreNode extends StateStoreNode
storeBuilder
Constructor and Description |
---|
GlobalStoreNode(StoreBuilder<KeyValueStore> storeBuilder,
java.lang.String sourceName,
java.lang.String topic,
ConsumedInternal consumed,
java.lang.String processorName,
ProcessorSupplier stateUpdateSupplier) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
toString() |
void |
writeToTopology(InternalTopologyBuilder topologyBuilder) |
addChild, allParentsWrittenToTopology, buildPriority, children, clearChildren, hasWrittenToTopology, isKeyChangingOperation, isMergeNode, isValueChangingOperation, keyChangingOperation, nodeName, parentNodes, removeChild, repartitionRequired, setBuildPriority, setHasWrittenToTopology, setMergeNode, setValueChangingOperation
public GlobalStoreNode(StoreBuilder<KeyValueStore> storeBuilder, java.lang.String sourceName, java.lang.String topic, ConsumedInternal consumed, java.lang.String processorName, ProcessorSupplier stateUpdateSupplier)
public void writeToTopology(InternalTopologyBuilder topologyBuilder)
writeToTopology
in class StateStoreNode
public java.lang.String toString()
toString
in class StateStoreNode