Class StreamsGraphNode
- java.lang.Object
-
- org.apache.kafka.streams.kstream.internals.graph.StreamsGraphNode
-
- Direct Known Subclasses:
BaseRepartitionNode
,KTableKTableJoinNode
,ProcessorGraphNode
,StateStoreNode
,StreamSinkNode
,StreamSourceNode
,StreamStreamJoinNode
,StreamTableJoinNode
,StreamToTableNode
,TableProcessorNode
public abstract class StreamsGraphNode extends Object
-
-
Constructor Summary
Constructors Constructor Description StreamsGraphNode(String nodeName)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
addChild(StreamsGraphNode childNode)
boolean
allParentsWrittenToTopology()
Integer
buildPriority()
Collection<StreamsGraphNode>
children()
void
clearChildren()
boolean
hasWrittenToTopology()
boolean
isKeyChangingOperation()
boolean
isMergeNode()
boolean
isValueChangingOperation()
void
keyChangingOperation(boolean keyChangingOperation)
String
nodeName()
Collection<StreamsGraphNode>
parentNodes()
boolean
removeChild(StreamsGraphNode child)
void
setBuildPriority(int buildPriority)
void
setHasWrittenToTopology(boolean hasWrittenToTopology)
void
setMergeNode(boolean mergeNode)
void
setValueChangingOperation(boolean valueChangingOperation)
String
toString()
abstract void
writeToTopology(InternalTopologyBuilder topologyBuilder)
-
-
-
Constructor Detail
-
StreamsGraphNode
public StreamsGraphNode(String nodeName)
-
-
Method Detail
-
parentNodes
public Collection<StreamsGraphNode> parentNodes()
-
allParentsWrittenToTopology
public boolean allParentsWrittenToTopology()
-
children
public Collection<StreamsGraphNode> children()
-
clearChildren
public void clearChildren()
-
removeChild
public boolean removeChild(StreamsGraphNode child)
-
addChild
public void addChild(StreamsGraphNode childNode)
-
nodeName
public String nodeName()
-
isKeyChangingOperation
public boolean isKeyChangingOperation()
-
isValueChangingOperation
public boolean isValueChangingOperation()
-
isMergeNode
public boolean isMergeNode()
-
setMergeNode
public void setMergeNode(boolean mergeNode)
-
setValueChangingOperation
public void setValueChangingOperation(boolean valueChangingOperation)
-
keyChangingOperation
public void keyChangingOperation(boolean keyChangingOperation)
-
setBuildPriority
public void setBuildPriority(int buildPriority)
-
buildPriority
public Integer buildPriority()
-
writeToTopology
public abstract void writeToTopology(InternalTopologyBuilder topologyBuilder)
-
hasWrittenToTopology
public boolean hasWrittenToTopology()
-
setHasWrittenToTopology
public void setHasWrittenToTopology(boolean hasWrittenToTopology)
-
-