Class JobTopology
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology
-
public class JobTopology extends java.lang.Object
Structure representing information about the jobgraph that is relevant for scaling.
-
-
Constructor Summary
Constructors Constructor Description JobTopology(java.util.Set<VertexInfo> vertexInfo)
JobTopology(VertexInfo... vertexInfo)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static JobTopology
fromJsonPlan(java.lang.String jsonPlan, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.lang.Integer> maxParallelismMap)
java.util.List<org.apache.flink.runtime.jobgraph.JobVertexID>
getVerticesInTopologicalOrder()
boolean
isSource(org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID)
void
updateMaxParallelism(org.apache.flink.runtime.jobgraph.JobVertexID vertexID, int maxParallelism)
-
-
-
Constructor Detail
-
JobTopology
public JobTopology(VertexInfo... vertexInfo)
-
JobTopology
public JobTopology(java.util.Set<VertexInfo> vertexInfo)
-
-
Method Detail
-
isSource
public boolean isSource(org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID)
-
updateMaxParallelism
public void updateMaxParallelism(org.apache.flink.runtime.jobgraph.JobVertexID vertexID, int maxParallelism)
-
getVerticesInTopologicalOrder
public java.util.List<org.apache.flink.runtime.jobgraph.JobVertexID> getVerticesInTopologicalOrder()
-
fromJsonPlan
public static JobTopology fromJsonPlan(java.lang.String jsonPlan, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.lang.Integer> maxParallelismMap) throws com.fasterxml.jackson.core.JsonProcessingException
- Throws:
com.fasterxml.jackson.core.JsonProcessingException
-
-