Package org.apache.flink.streaming.api.graph.util

Class OperatorInfo

java.lang.Object

org.apache.flink.streaming.api.graph.util.OperatorInfo

@Internal
public class OperatorInfo
extends Object

Helper class to help maintain the information of an operator.

Constructor Summary

Constructors

Constructor	Description
OperatorInfo()

Method Summary

Modifier and Type	Method	Description
void	addChainableOutputs(List<StreamEdge> chainableOutputs)
void	addNonChainableOutputs(List<StreamEdge> nonChainableOutEdges)
List<StreamEdge>	getChainableOutputs()
List<StreamEdge>	getNonChainableOutputs()
StreamConfig	getVertexConfig()
void	setVertexConfig(StreamConfig vertexConfig)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OperatorInfo

public OperatorInfo()

Method Detail

getChainableOutputs

public List<StreamEdge> getChainableOutputs()

addChainableOutputs

public void addChainableOutputs(List<StreamEdge> chainableOutputs)

getNonChainableOutputs

public List<StreamEdge> getNonChainableOutputs()

addNonChainableOutputs

public void addNonChainableOutputs(List<StreamEdge> nonChainableOutEdges)

getVertexConfig

public StreamConfig getVertexConfig()

setVertexConfig

public void setVertexConfig(StreamConfig vertexConfig)