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(Integer id, String slotSharingGroup, String coLocationGroup, StreamOperator<?> operator, String operatorName, List<OutputSelector<?>> outputSelector, Class<? extends AbstractInvokable> jobVertexClass)
StreamNode(Integer id, String slotSharingGroup, String coLocationGroup, StreamOperatorFactory<?> operatorFactory, 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()
String	getCoLocationGroup()
Optional<OperatorCoordinator.Provider>	getCoordinatorProvider(String operatorName, OperatorID operatorID)
int	getId()
List<Integer>	getInEdgeIndices()
List<StreamEdge>	getInEdges()
InputFormat<?,?>	getInputFormat()
Class<? extends AbstractInvokable>	getJobVertexClass()
int	getManagedMemoryWeight()
ResourceSpec	getMinResources()
StreamOperator<?>	getOperator()
StreamOperatorFactory<?>	getOperatorFactory()
String	getOperatorName()
List<Integer>	getOutEdgeIndices()
List<StreamEdge>	getOutEdges()
OutputFormat<?>	getOutputFormat()
List<OutputSelector<?>>	getOutputSelectors()
int	getParallelism()
ResourceSpec	getPreferredResources()
String	getSlotSharingGroup()
TypeSerializer<?>	getStateKeySerializer()
KeySelector<?,?>[]	getStatePartitioners()
String	getTransformationUID()
TypeSerializer<?>	getTypeSerializerIn(int index)
TypeSerializer<?>	getTypeSerializerOut()
TypeSerializer<?>[]	getTypeSerializersIn()
String	getUserHash()
int	hashCode()
boolean	isSameSlotSharingGroup(StreamNode downstreamVertex)
void	setBufferTimeout(Long bufferTimeout)
void	setCoLocationGroup(String coLocationGroup)
void	setInputFormat(InputFormat<?,?> inputFormat)
void	setManagedMemoryWeight(int managedMemoryWeight)
void	setOutputFormat(OutputFormat<?> outputFormat)
void	setParallelism(Integer parallelism)
void	setResources(ResourceSpec minResources, ResourceSpec preferredResources)
void	setSerializerOut(TypeSerializer<?> typeSerializerOut)
void	setSerializersIn(TypeSerializer<?>... typeSerializersIn)
void	setSlotSharingGroup(String slotSharingGroup)
void	setStateKeySerializer(TypeSerializer<?> stateKeySerializer)
void	setStatePartitioners(KeySelector<?,?>... statePartitioners)
void	setUserHash(String userHash)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

StreamNode

@VisibleForTesting
public StreamNode(Integer id,
                                     @Nullable
                                     String slotSharingGroup,
                                     @Nullable
                                     String coLocationGroup,
                                     StreamOperator<?> operator,
                                     String operatorName,
                                     List<OutputSelector<?>> outputSelector,
                                     Class<? extends AbstractInvokable> jobVertexClass)

StreamNode

public StreamNode(Integer id,
                  @Nullable
                  String slotSharingGroup,
                  @Nullable
                  String coLocationGroup,
                  StreamOperatorFactory<?> operatorFactory,
                  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)

setManagedMemoryWeight

public void setManagedMemoryWeight(int managedMemoryWeight)

getManagedMemoryWeight

public int getManagedMemoryWeight()

getBufferTimeout

public long getBufferTimeout()

setBufferTimeout

public void setBufferTimeout(Long bufferTimeout)

getOperator

@VisibleForTesting
public StreamOperator<?> getOperator()

getOperatorFactory

public StreamOperatorFactory<?> getOperatorFactory()

getOperatorName

public String getOperatorName()

getOutputSelectors

public List<OutputSelector<?>> getOutputSelectors()

addOutputSelector

public void addOutputSelector(OutputSelector<?> outputSelector)

setSerializersIn

public void setSerializersIn(TypeSerializer<?>... typeSerializersIn)

getTypeSerializersIn

public TypeSerializer<?>[] getTypeSerializersIn()

getTypeSerializerIn

public TypeSerializer<?> getTypeSerializerIn(int index)

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)

getOutputFormat

public OutputFormat<?> getOutputFormat()

setOutputFormat

public void setOutputFormat(OutputFormat<?> outputFormat)

setSlotSharingGroup

public void setSlotSharingGroup(@Nullable
                                String slotSharingGroup)

getSlotSharingGroup

@Nullable
public String getSlotSharingGroup()

setCoLocationGroup

public void setCoLocationGroup(@Nullable
                               String coLocationGroup)

getCoLocationGroup

@Nullable
public String getCoLocationGroup()

isSameSlotSharingGroup

public boolean isSameSlotSharingGroup(StreamNode downstreamVertex)

toString

public String toString()

Overrides:

toString in class Object

getStatePartitioners

public KeySelector<?,?>[] getStatePartitioners()

setStatePartitioners

public void setStatePartitioners(KeySelector<?,?>... statePartitioners)

getStateKeySerializer

public TypeSerializer<?> getStateKeySerializer()

setStateKeySerializer

public void setStateKeySerializer(TypeSerializer<?> stateKeySerializer)

getTransformationUID

public String getTransformationUID()

getUserHash

public String getUserHash()

setUserHash

public void setUserHash(String userHash)

getCoordinatorProvider

public Optional<OperatorCoordinator.Provider> getCoordinatorProvider(String operatorName,
                                                                     OperatorID operatorID)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object