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

Class JobVertexBuildContext

java.lang.Object

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

@Internal
public class JobVertexBuildContext
extends Object

Helper class encapsulates all necessary information and configurations required during the construction of job vertices.

Constructor Summary

Constructors

Constructor	Description
JobVertexBuildContext(StreamGraph streamGraph, AtomicBoolean hasHybridResultPartition, Map<Integer,byte[]> hashes, List<Map<Integer,byte[]>> legacyHashes)

Method Summary

Modifier and Type	Method	Description
void	addChainInfo(Integer startNodeId, OperatorChainInfo chainInfo)
void	addJobVertex(Integer startNodeId, JobVertex jobVertex)
void	addPhysicalEdgesInOrder(StreamEdge edge)
OperatorInfo	createAndGetOperatorInfo(Integer nodeId)
Map<Integer,Map<Integer,StreamConfig>>	getChainedConfigs()
OperatorChainInfo	getChainInfo(Integer startNodeId)
Map<Integer,OperatorChainInfo>	getChainInfosInOrder()
Map<JobVertexID,List<CompletableFuture<SerializedValue<OperatorCoordinator.Provider>>>>	getCoordinatorSerializationFuturesPerJobVertex()
byte[]	getHash(Integer streamNodeId)
JobVertex	getJobVertex(Integer startNodeId)
Map<Integer,JobVertex>	getJobVerticesInOrder()
List<byte[]>	getLegacyHashes(Integer streamNodeId)
OperatorInfo	getOperatorInfo(Integer nodeId)
Map<Integer,OperatorInfo>	getOperatorInfos()
Map<Integer,StreamConfig>	getOrCreateChainedConfig(Integer streamNodeId)
List<StreamEdge>	getPhysicalEdgesInOrder()
StreamGraph	getStreamGraph()
boolean	hasHybridResultPartition()
void	putCoordinatorSerializationFutures(JobVertexID vertexId, List<CompletableFuture<SerializedValue<OperatorCoordinator.Provider>>> serializationFutures)
void	setHasHybridResultPartition(boolean hasHybridResultPartition)

Methods inherited from class java.lang.Object

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

Constructor Detail

JobVertexBuildContext

public JobVertexBuildContext(StreamGraph streamGraph,
                             AtomicBoolean hasHybridResultPartition,
                             Map<Integer,byte[]> hashes,
                             List<Map<Integer,byte[]>> legacyHashes)

Method Detail

addChainInfo

public void addChainInfo(Integer startNodeId,
                         OperatorChainInfo chainInfo)

getChainInfo

public OperatorChainInfo getChainInfo(Integer startNodeId)

getChainInfosInOrder

public Map<Integer,OperatorChainInfo> getChainInfosInOrder()

getOperatorInfo

public OperatorInfo getOperatorInfo(Integer nodeId)

createAndGetOperatorInfo

public OperatorInfo createAndGetOperatorInfo(Integer nodeId)

getOperatorInfos

public Map<Integer,OperatorInfo> getOperatorInfos()

getStreamGraph

public StreamGraph getStreamGraph()

hasHybridResultPartition

public boolean hasHybridResultPartition()

setHasHybridResultPartition

public void setHasHybridResultPartition(boolean hasHybridResultPartition)

addPhysicalEdgesInOrder

public void addPhysicalEdgesInOrder(StreamEdge edge)

getPhysicalEdgesInOrder

public List<StreamEdge> getPhysicalEdgesInOrder()

addJobVertex

public void addJobVertex(Integer startNodeId,
                         JobVertex jobVertex)

getJobVerticesInOrder

public Map<Integer,JobVertex> getJobVerticesInOrder()

getJobVertex

public JobVertex getJobVertex(Integer startNodeId)

putCoordinatorSerializationFutures

public void putCoordinatorSerializationFutures(JobVertexID vertexId,
                                               List<CompletableFuture<SerializedValue<OperatorCoordinator.Provider>>> serializationFutures)

getCoordinatorSerializationFuturesPerJobVertex

public Map<JobVertexID,List<CompletableFuture<SerializedValue<OperatorCoordinator.Provider>>>> getCoordinatorSerializationFuturesPerJobVertex()

getChainedConfigs

public Map<Integer,Map<Integer,StreamConfig>> getChainedConfigs()

getOrCreateChainedConfig

public Map<Integer,StreamConfig> getOrCreateChainedConfig(Integer streamNodeId)

getHash

public byte[] getHash(Integer streamNodeId)

getLegacyHashes

public List<byte[]> getLegacyHashes(Integer streamNodeId)