Package org.apache.flink.autoscaler.topology

Class VertexInfo

  • public class VertexInfo
extends java.lang.Object
    Job vertex information.

    • Constructor Summary

      Constructors 
      Constructor Description
      VertexInfo​(org.apache.flink.runtime.jobgraph.JobVertexID id, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​ShipStrategy> inputs, int parallelism, int maxParallelism)  
      VertexInfo​(org.apache.flink.runtime.jobgraph.JobVertexID id, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​ShipStrategy> inputs, int parallelism, int maxParallelism, boolean finished, IOMetrics ioMetrics)  
      VertexInfo​(org.apache.flink.runtime.jobgraph.JobVertexID id, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​ShipStrategy> inputs, int parallelism, int maxParallelism, IOMetrics ioMetrics)  
      VertexInfo​(org.apache.flink.runtime.jobgraph.JobVertexID id, org.apache.flink.runtime.instance.SlotSharingGroupId slotSharingGroupId, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​ShipStrategy> inputs, int parallelism, int maxParallelism, boolean finished, IOMetrics ioMetrics)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void updateMaxParallelism​(int maxParallelism)  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • VertexInfo

        public VertexInfo​(org.apache.flink.runtime.jobgraph.JobVertexID id,
                  org.apache.flink.runtime.instance.SlotSharingGroupId slotSharingGroupId,
                  java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​ShipStrategy> inputs,
                  int parallelism,
                  int maxParallelism,
                  boolean finished,
                  IOMetrics ioMetrics)

      • VertexInfo

        @VisibleForTesting
public VertexInfo​(org.apache.flink.runtime.jobgraph.JobVertexID id,
                  java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​ShipStrategy> inputs,
                  int parallelism,
                  int maxParallelism,
                  IOMetrics ioMetrics)

      • VertexInfo

        @VisibleForTesting
public VertexInfo​(org.apache.flink.runtime.jobgraph.JobVertexID id,
                  java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​ShipStrategy> inputs,
                  int parallelism,
                  int maxParallelism,
                  boolean finished,
                  IOMetrics ioMetrics)

      • VertexInfo

        @VisibleForTesting
public VertexInfo​(org.apache.flink.runtime.jobgraph.JobVertexID id,
                  java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,​ShipStrategy> inputs,
                  int parallelism,
                  int maxParallelism)

    • Method Detail

      • updateMaxParallelism

        public void updateMaxParallelism​(int maxParallelism)