Package org.apache.flink.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,​org.apache.flink.runtime.instance.SlotSharingGroupId> slotSharingGroupIdMap, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​java.lang.Integer> maxParallelismMap, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​IOMetrics> metrics, java.util.Set<org.apache.flink.runtime.jobgraph.JobVertexID> finishedVertices)  
      VertexInfo get​(org.apache.flink.runtime.jobgraph.JobVertexID jvi)  
      boolean isSource​(org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • JobTopology

        public JobTopology​(java.util.Collection<VertexInfo> vertexInfo)

      • JobTopology

        public JobTopology​(VertexInfo... vertexInfo)

      • JobTopology

        public JobTopology​(java.util.Set<VertexInfo> vertexInfo)

    • Method Detail

      • get

        public VertexInfo get​(org.apache.flink.runtime.jobgraph.JobVertexID jvi)

      • isSource

        public boolean isSource​(org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID)

      • fromJsonPlan

        public static JobTopology fromJsonPlan​(java.lang.String jsonPlan,
                                       java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​org.apache.flink.runtime.instance.SlotSharingGroupId> slotSharingGroupIdMap,
                                       java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​java.lang.Integer> maxParallelismMap,
                                       java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​IOMetrics> metrics,
                                       java.util.Set<org.apache.flink.runtime.jobgraph.JobVertexID> finishedVertices)
                                throws org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonProcessingException
        Throws:
        org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonProcessingException