public abstract class StreamsGraphNode
extends java.lang.Object
Constructor and Description |
---|
StreamsGraphNode(java.lang.String nodeName,
boolean repartitionRequired) |
Modifier and Type | Method and Description |
---|---|
void |
addChild(StreamsGraphNode childNode) |
boolean |
allParentsWrittenToTopology() |
java.lang.Integer |
buildPriority() |
java.util.Collection<StreamsGraphNode> |
children() |
void |
clearChildren() |
boolean |
hasWrittenToTopology() |
boolean |
isKeyChangingOperation() |
boolean |
isMergeNode() |
boolean |
isValueChangingOperation() |
void |
keyChangingOperation(boolean keyChangingOperation) |
java.lang.String |
nodeName() |
java.util.Collection<StreamsGraphNode> |
parentNodes() |
boolean |
removeChild(StreamsGraphNode child) |
boolean |
repartitionRequired() |
void |
setBuildPriority(int buildPriority) |
void |
setHasWrittenToTopology(boolean hasWrittenToTopology) |
void |
setMergeNode(boolean mergeNode) |
void |
setValueChangingOperation(boolean valueChangingOperation) |
java.lang.String |
toString() |
abstract void |
writeToTopology(InternalTopologyBuilder topologyBuilder) |
public StreamsGraphNode(java.lang.String nodeName, boolean repartitionRequired)
public java.util.Collection<StreamsGraphNode> parentNodes()
public boolean allParentsWrittenToTopology()
public java.util.Collection<StreamsGraphNode> children()
public void clearChildren()
public boolean removeChild(StreamsGraphNode child)
public void addChild(StreamsGraphNode childNode)
public java.lang.String nodeName()
public boolean repartitionRequired()
public boolean isKeyChangingOperation()
public boolean isValueChangingOperation()
public boolean isMergeNode()
public void setMergeNode(boolean mergeNode)
public void setValueChangingOperation(boolean valueChangingOperation)
public void keyChangingOperation(boolean keyChangingOperation)
public void setBuildPriority(int buildPriority)
public java.lang.Integer buildPriority()
public abstract void writeToTopology(InternalTopologyBuilder topologyBuilder)
public boolean hasWrittenToTopology()
public void setHasWrittenToTopology(boolean hasWrittenToTopology)
public java.lang.String toString()
toString
in class java.lang.Object