Package org.apache.kafka.streams.kstream.internals.graph

Class GlobalStoreNode<K,V,S extends StateStore>

java.lang.Object

org.apache.kafka.streams.kstream.internals.graph.StreamsGraphNode

org.apache.kafka.streams.kstream.internals.graph.StateStoreNode<S>

org.apache.kafka.streams.kstream.internals.graph.GlobalStoreNode<K,V,S>

public class GlobalStoreNode<K,V,S extends StateStore>
extends StateStoreNode<S>

Field Summary

Fields inherited from class org.apache.kafka.streams.kstream.internals.graph.StateStoreNode

storeBuilder

Constructor Summary

Constructors

Constructor	Description
GlobalStoreNode(StoreBuilder<S> storeBuilder, String sourceName, String topic, ConsumedInternal<K,V> consumed, String processorName, ProcessorSupplier<K,V> stateUpdateSupplier)

Method Summary

Modifier and Type	Method	Description
String	toString()
void	writeToTopology(InternalTopologyBuilder topologyBuilder)

Methods inherited from class org.apache.kafka.streams.kstream.internals.graph.StreamsGraphNode

addChild, allParentsWrittenToTopology, buildPriority, children, clearChildren, hasWrittenToTopology, isKeyChangingOperation, isMergeNode, isValueChangingOperation, keyChangingOperation, nodeName, parentNodes, removeChild, setBuildPriority, setHasWrittenToTopology, setMergeNode, setValueChangingOperation

Methods inherited from class java.lang.Object

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

Constructor Detail

GlobalStoreNode

public GlobalStoreNode(StoreBuilder<S> storeBuilder,
                       String sourceName,
                       String topic,
                       ConsumedInternal<K,V> consumed,
                       String processorName,
                       ProcessorSupplier<K,V> stateUpdateSupplier)

Method Detail

writeToTopology

public void writeToTopology(InternalTopologyBuilder topologyBuilder)

Overrides:

writeToTopology in class StateStoreNode<S extends StateStore>

toString

public String toString()

Overrides:

toString in class StateStoreNode<S extends StateStore>