org.apache.flink.streaming.api.graph

Class StreamNode

java.lang.Object

org.apache.flink.streaming.api.graph.StreamNode

All Implemented Interfaces:

Serializable

@Internal
public class StreamNode
extends Object
implements Serializable

Class representing the operators in the streaming programs, with all their properties.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
StreamNode(StreamExecutionEnvironment env, Integer id, String slotSharingGroup, StreamOperator<?> operator, String operatorName, List<OutputSelector<?>> outputSelector, Class<? extends AbstractInvokable> jobVertexClass)

Method Summary

Modifier and Type	Method and Description
void	addInEdge(StreamEdge inEdge)
void	addOutEdge(StreamEdge outEdge)
void	addOutputSelector(OutputSelector<?> outputSelector)
boolean	equals(Object o)
Long	getBufferTimeout()
int	getId()
List<Integer>	getInEdgeIndices()
List<StreamEdge>	getInEdges()
InputFormat<?,?>	getInputFormat()
Class<? extends AbstractInvokable>	getJobVertexClass()
ResourceSpec	getMinResources()
StreamOperator<?>	getOperator()
String	getOperatorName()
List<Integer>	getOutEdgeIndices()
List<StreamEdge>	getOutEdges()
List<OutputSelector<?>>	getOutputSelectors()
int	getParallelism()
ResourceSpec	getPreferredResources()
String	getSlotSharingGroup()
TypeSerializer<?>	getStateKeySerializer()
KeySelector<?,?>	getStatePartitioner1()
KeySelector<?,?>	getStatePartitioner2()
String	getTransformationUID()
TypeSerializer<?>	getTypeSerializerIn1()
TypeSerializer<?>	getTypeSerializerIn2()
TypeSerializer<?>	getTypeSerializerOut()
String	getUserHash()
int	hashCode()
boolean	isSameSlotSharingGroup(StreamNode downstreamVertex)
void	setBufferTimeout(Long bufferTimeout)
void	setInputFormat(InputFormat<?,?> inputFormat)
void	setOperator(StreamOperator<?> operator)
void	setParallelism(Integer parallelism)
void	setResources(ResourceSpec minResources, ResourceSpec preferredResources)
void	setSerializerIn1(TypeSerializer<?> typeSerializerIn1)
void	setSerializerIn2(TypeSerializer<?> typeSerializerIn2)
void	setSerializerOut(TypeSerializer<?> typeSerializerOut)
void	setSlotSharingGroup(String slotSharingGroup)
void	setStateKeySerializer(TypeSerializer<?> stateKeySerializer)
void	setStatePartitioner1(KeySelector<?,?> statePartitioner)
void	setStatePartitioner2(KeySelector<?,?> statePartitioner)
void	setUserHash(String userHash)
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

StreamNode

public StreamNode(StreamExecutionEnvironment env,
                  Integer id,
                  String slotSharingGroup,
                  StreamOperator<?> operator,
                  String operatorName,
                  List<OutputSelector<?>> outputSelector,
                  Class<? extends AbstractInvokable> jobVertexClass)

Method Detail

addInEdge

public void addInEdge(StreamEdge inEdge)

addOutEdge

public void addOutEdge(StreamEdge outEdge)

getOutEdges

public List<StreamEdge> getOutEdges()

getInEdges

public List<StreamEdge> getInEdges()

getOutEdgeIndices

public List<Integer> getOutEdgeIndices()

getInEdgeIndices

public List<Integer> getInEdgeIndices()

getId

public int getId()

getParallelism

public int getParallelism()

setParallelism

public void setParallelism(Integer parallelism)

getMinResources

public ResourceSpec getMinResources()

getPreferredResources

public ResourceSpec getPreferredResources()

setResources

public void setResources(ResourceSpec minResources,
                         ResourceSpec preferredResources)

getBufferTimeout

public Long getBufferTimeout()

setBufferTimeout

public void setBufferTimeout(Long bufferTimeout)

getOperator

public StreamOperator<?> getOperator()

setOperator

public void setOperator(StreamOperator<?> operator)

getOperatorName

public String getOperatorName()

getOutputSelectors

public List<OutputSelector<?>> getOutputSelectors()

addOutputSelector

public void addOutputSelector(OutputSelector<?> outputSelector)

getTypeSerializerIn1

public TypeSerializer<?> getTypeSerializerIn1()

setSerializerIn1

public void setSerializerIn1(TypeSerializer<?> typeSerializerIn1)

getTypeSerializerIn2

public TypeSerializer<?> getTypeSerializerIn2()

setSerializerIn2

public void setSerializerIn2(TypeSerializer<?> typeSerializerIn2)

getTypeSerializerOut

public TypeSerializer<?> getTypeSerializerOut()

setSerializerOut

public void setSerializerOut(TypeSerializer<?> typeSerializerOut)

getJobVertexClass

public Class<? extends AbstractInvokable> getJobVertexClass()

getInputFormat

public InputFormat<?,?> getInputFormat()

setInputFormat

public void setInputFormat(InputFormat<?,?> inputFormat)

setSlotSharingGroup

public void setSlotSharingGroup(String slotSharingGroup)

getSlotSharingGroup

public String getSlotSharingGroup()

isSameSlotSharingGroup

public boolean isSameSlotSharingGroup(StreamNode downstreamVertex)

toString

public String toString()

Overrides:

toString in class Object

getStatePartitioner1

public KeySelector<?,?> getStatePartitioner1()

getStatePartitioner2

public KeySelector<?,?> getStatePartitioner2()

setStatePartitioner1

public void setStatePartitioner1(KeySelector<?,?> statePartitioner)

setStatePartitioner2

public void setStatePartitioner2(KeySelector<?,?> statePartitioner)

getStateKeySerializer

public TypeSerializer<?> getStateKeySerializer()

setStateKeySerializer

public void setStateKeySerializer(TypeSerializer<?> stateKeySerializer)

getTransformationUID

public String getTransformationUID()

getUserHash

public String getUserHash()

setUserHash

public void setUserHash(String userHash)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object