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

Class StatefulProcessorNode<K,V>

java.lang.Object

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

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

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

public class StatefulProcessorNode<K,V>
extends ProcessorGraphNode<K,V>

Constructor Summary

Constructors

Constructor	Description
StatefulProcessorNode(String nodeName, ProcessorParameters<K,V> processorParameters, String[] storeNames)	Create a node representing a stateful processor, where the named stores have already been registered.
StatefulProcessorNode(String nodeName, ProcessorParameters<K,V> processorParameters, StoreBuilder<?> materializedKTableStoreBuilder)	Create a node representing a stateful processor, where the store needs to be built and registered as part of building this node.
StatefulProcessorNode(ProcessorParameters<K,V> processorParameters, Set<StoreBuilder<?>> preRegisteredStores, Set<KTableValueGetterSupplier<?,?>> valueGetterSuppliers)	Create a node representing a stateful processor, where the named stores have already been registered.

Method Summary

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

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

processorParameters

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

StatefulProcessorNode

public StatefulProcessorNode(ProcessorParameters<K,V> processorParameters,
                             Set<StoreBuilder<?>> preRegisteredStores,
                             Set<KTableValueGetterSupplier<?,?>> valueGetterSuppliers)

Create a node representing a stateful processor, where the named stores have already been registered.

StatefulProcessorNode

public StatefulProcessorNode(String nodeName,
                             ProcessorParameters<K,V> processorParameters,
                             String[] storeNames)

Create a node representing a stateful processor, where the named stores have already been registered.

StatefulProcessorNode

public StatefulProcessorNode(String nodeName,
                             ProcessorParameters<K,V> processorParameters,
                             StoreBuilder<?> materializedKTableStoreBuilder)

Create a node representing a stateful processor, where the store needs to be built and registered as part of building this node.

Method Detail

toString

public String toString()

Overrides:

toString in class ProcessorGraphNode<K,V>

writeToTopology

public void writeToTopology(InternalTopologyBuilder topologyBuilder)

Overrides:

writeToTopology in class ProcessorGraphNode<K,V>