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

Class OperatorChainInfo

java.lang.Object

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

@Internal
public class OperatorChainInfo
extends Object

Helper class to help maintain the information of an operator chain.

Constructor Summary

Constructors

Constructor	Description
OperatorChainInfo(int startNodeId, Map<Integer,ChainedSourceInfo> chainedSources, StreamGraph streamGraph)

Method Summary

Modifier and Type	Method	Description
void	addChainedMinResources(Integer sourceNodeId, ResourceSpec resourceSpec)
void	addChainedName(Integer streamNodeId, String chainedName)
void	addChainedPreferredResources(Integer sourceNodeId, ResourceSpec resourceSpec)
void	addChainedSource(Integer sourceNodeId, ChainedSourceInfo chainedSourceInfo)
void	addCoordinatorProvider(OperatorCoordinator.Provider coordinator)
OperatorID	addNodeToChain(int currentNodeId, String operatorName, JobVertexBuildContext jobVertexBuildContext)
void	addTransitiveInEdge(StreamEdge streamEdge)
List<StreamNode>	getAllChainedNodes()
ResourceSpec	getChainedMinResources(Integer sourceNodeId)
String	getChainedName(Integer streamNodeId)
Map<Integer,String>	getChainedNames()
List<ChainedOperatorHashInfo>	getChainedOperatorHashes(int startNodeId)
ResourceSpec	getChainedPreferredResources(Integer sourceNodeId)
Map<Integer,ChainedSourceInfo>	getChainedSources()
List<OperatorCoordinator.Provider>	getCoordinatorProviders()
InputOutputFormatContainer	getOrCreateFormatContainer()
Integer	getStartNodeId()
List<StreamEdge>	getTransitiveInEdges()
List<StreamEdge>	getTransitiveOutEdges()
boolean	hasFormatContainer()
OperatorChainInfo	newChain(Integer startNodeId)
void	recordChainedNode(int currentNodeId)
void	setTransitiveOutEdges(List<StreamEdge> transitiveOutEdges)

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorChainInfo

public OperatorChainInfo(int startNodeId,
                         Map<Integer,ChainedSourceInfo> chainedSources,
                         StreamGraph streamGraph)

Method Detail

getStartNodeId

public Integer getStartNodeId()

getChainedOperatorHashes

public List<ChainedOperatorHashInfo> getChainedOperatorHashes(int startNodeId)

addCoordinatorProvider

public void addCoordinatorProvider(OperatorCoordinator.Provider coordinator)

getCoordinatorProviders

public List<OperatorCoordinator.Provider> getCoordinatorProviders()

getChainedSources

public Map<Integer,ChainedSourceInfo> getChainedSources()

addNodeToChain

public OperatorID addNodeToChain(int currentNodeId,
                                 String operatorName,
                                 JobVertexBuildContext jobVertexBuildContext)

setTransitiveOutEdges

public void setTransitiveOutEdges(List<StreamEdge> transitiveOutEdges)

getTransitiveOutEdges

public List<StreamEdge> getTransitiveOutEdges()

recordChainedNode

public void recordChainedNode(int currentNodeId)

newChain

public OperatorChainInfo newChain(Integer startNodeId)

getAllChainedNodes

public List<StreamNode> getAllChainedNodes()

hasFormatContainer

public boolean hasFormatContainer()

getOrCreateFormatContainer

public InputOutputFormatContainer getOrCreateFormatContainer()

addChainedSource

public void addChainedSource(Integer sourceNodeId,
                             ChainedSourceInfo chainedSourceInfo)

addChainedMinResources

public void addChainedMinResources(Integer sourceNodeId,
                                   ResourceSpec resourceSpec)

getChainedMinResources

public ResourceSpec getChainedMinResources(Integer sourceNodeId)

addChainedPreferredResources

public void addChainedPreferredResources(Integer sourceNodeId,
                                         ResourceSpec resourceSpec)

getChainedPreferredResources

public ResourceSpec getChainedPreferredResources(Integer sourceNodeId)

getChainedName

public String getChainedName(Integer streamNodeId)

getChainedNames

public Map<Integer,String> getChainedNames()

addChainedName

public void addChainedName(Integer streamNodeId,
                           String chainedName)

addTransitiveInEdge

public void addTransitiveInEdge(StreamEdge streamEdge)

getTransitiveInEdges

public List<StreamEdge> getTransitiveInEdges()