Package org.apache.flink.kubernetes.operator.autoscaler.topology

Class JobTopology

  • public class JobTopology
extends java.lang.Object
    Structure representing information about the jobgraph that is relevant for scaling.

    • 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)  

      • Methods inherited from class java.lang.Object

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

    • 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