org.apache.flink.streaming.api.graph

Class StreamNode

java.lang.Object

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

@Internal
public class StreamNode
extends Object

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

Constructor Summary

Constructors

Constructor and Description
StreamNode(Integer id, String slotSharingGroup, String coLocationGroup, StreamOperator<?> operator, String operatorName, Class<? extends TaskInvokable> jobVertexClass)
StreamNode(Integer id, String slotSharingGroup, String coLocationGroup, StreamOperatorFactory<?> operatorFactory, String operatorName, Class<? extends TaskInvokable> jobVertexClass)

Method Summary

Modifier and Type	Method and Description
void	addInEdge(StreamEdge inEdge)
void	addInputRequirement(int inputIndex, StreamConfig.InputRequirement inputRequirement)
void	addOutEdge(StreamEdge outEdge)
boolean	equals(Object o)
long	getBufferTimeout()
String	getCoLocationGroup()
IntermediateDataSetID	getConsumeClusterDatasetId()
Optional<OperatorCoordinator.Provider>	getCoordinatorProvider(String operatorName, OperatorID operatorID)
int	getId()
List<Integer>	getInEdgeIndices()
List<StreamEdge>	getInEdges()
InputFormat<?,?>	getInputFormat()
Map<Integer,StreamConfig.InputRequirement>	getInputRequirements()
Class<? extends TaskInvokable>	getJobVertexClass()
Map<ManagedMemoryUseCase,Integer>	getManagedMemoryOperatorScopeUseCaseWeights()
Set<ManagedMemoryUseCase>	getManagedMemorySlotScopeUseCases()
ResourceSpec	getMinResources()
StreamOperator<?>	getOperator()
String	getOperatorDescription()
StreamOperatorFactory<?>	getOperatorFactory()
String	getOperatorName()
List<Integer>	getOutEdgeIndices()
List<StreamEdge>	getOutEdges()
OutputFormat<?>	getOutputFormat()
int	getParallelism()
ResourceSpec	getPreferredResources()
String	getSlotSharingGroup()
TypeSerializer<?>	getStateKeySerializer()
KeySelector<?,?>[]	getStatePartitioners()
String	getTransformationUID()
TypeSerializer<?>	getTypeSerializerOut()
TypeSerializer<?>[]	getTypeSerializersIn()
String	getUserHash()
int	hashCode()
boolean	isOutputOnlyAfterEndOfStream()
boolean	isSameSlotSharingGroup(StreamNode downstreamVertex)
boolean	isSupportsConcurrentExecutionAttempts()
void	setBufferTimeout(Long bufferTimeout)
void	setCoLocationGroup(String coLocationGroup)
void	setConsumeClusterDatasetId(IntermediateDataSetID consumeClusterDatasetId)
void	setInputFormat(InputFormat<?,?> inputFormat)
void	setManagedMemoryUseCaseWeights(Map<ManagedMemoryUseCase,Integer> operatorScopeUseCaseWeights, Set<ManagedMemoryUseCase> slotScopeUseCases)
void	setOperatorDescription(String operatorDescription)
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	setSupportsConcurrentExecutionAttempts(boolean supportsConcurrentExecutionAttempts)
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,
                                     @Nullable
                                     StreamOperator<?> operator,
                                     String operatorName,
                                     Class<? extends TaskInvokable> jobVertexClass)

StreamNode

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

setManagedMemoryUseCaseWeights

public void setManagedMemoryUseCaseWeights(Map<ManagedMemoryUseCase,Integer> operatorScopeUseCaseWeights,
                                           Set<ManagedMemoryUseCase> slotScopeUseCases)

getManagedMemoryOperatorScopeUseCaseWeights

public Map<ManagedMemoryUseCase,Integer> getManagedMemoryOperatorScopeUseCaseWeights()

getManagedMemorySlotScopeUseCases

public Set<ManagedMemoryUseCase> getManagedMemorySlotScopeUseCases()

getBufferTimeout

public long getBufferTimeout()

setBufferTimeout

public void setBufferTimeout(Long bufferTimeout)

getOperator

@VisibleForTesting
public StreamOperator<?> getOperator()

getOperatorFactory

@Nullable
public StreamOperatorFactory<?> getOperatorFactory()

getOperatorName

public String getOperatorName()

getOperatorDescription

public String getOperatorDescription()

setOperatorDescription

public void setOperatorDescription(String operatorDescription)

setSerializersIn

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

getTypeSerializersIn

public TypeSerializer<?>[] getTypeSerializersIn()

getTypeSerializerOut

public TypeSerializer<?> getTypeSerializerOut()

setSerializerOut

public void setSerializerOut(TypeSerializer<?> typeSerializerOut)

getJobVertexClass

public Class<? extends TaskInvokable> 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)

addInputRequirement

public void addInputRequirement(int inputIndex,
                                StreamConfig.InputRequirement inputRequirement)

getInputRequirements

public Map<Integer,StreamConfig.InputRequirement> getInputRequirements()

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

getConsumeClusterDatasetId

@Nullable
public IntermediateDataSetID getConsumeClusterDatasetId()

setConsumeClusterDatasetId

public void setConsumeClusterDatasetId(@Nullable
                                       IntermediateDataSetID consumeClusterDatasetId)

isSupportsConcurrentExecutionAttempts

public boolean isSupportsConcurrentExecutionAttempts()

setSupportsConcurrentExecutionAttempts

public void setSupportsConcurrentExecutionAttempts(boolean supportsConcurrentExecutionAttempts)

isOutputOnlyAfterEndOfStream

public boolean isOutputOnlyAfterEndOfStream()