public class ProcessorGraphNode<K,V> extends StreamsGraphNode
Constructor and Description |
---|
ProcessorGraphNode(java.lang.String nodeName,
ProcessorParameters<K,V> processorParameters) |
ProcessorGraphNode(java.lang.String nodeName,
ProcessorParameters<K,V> processorParameters,
boolean repartitionRequired) |
Modifier and Type | Method and Description |
---|---|
ProcessorParameters |
processorParameters() |
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 ProcessorGraphNode(java.lang.String nodeName, ProcessorParameters<K,V> processorParameters, boolean repartitionRequired)
public ProcessorGraphNode(java.lang.String nodeName, ProcessorParameters<K,V> processorParameters)
public ProcessorParameters processorParameters()
public java.lang.String toString()
toString
in class StreamsGraphNode
public void writeToTopology(InternalTopologyBuilder topologyBuilder)
writeToTopology
in class StreamsGraphNode