Uses of Class
org.apache.flink.autoscaler.topology.ShipStrategy
-
Packages that use ShipStrategy Package Description org.apache.flink.autoscaler org.apache.flink.autoscaler.topology -
-
Uses of ShipStrategy in org.apache.flink.autoscaler
Method parameters in org.apache.flink.autoscaler with type arguments of type ShipStrategy Modifier and Type Method Description int
JobVertexScaler. computeScaleTargetParallelism(Context context, org.apache.flink.runtime.jobgraph.JobVertexID vertex, java.util.Collection<ShipStrategy> inputShipStrategies, java.util.Map<ScalingMetric,EvaluatedScalingMetric> evaluatedMetrics, java.util.SortedMap<java.time.Instant,ScalingSummary> history, java.time.Duration restartTime)
protected static int
JobVertexScaler. scale(int currentParallelism, java.util.Collection<ShipStrategy> inputShipStrategies, int maxParallelism, double scaleFactor, int parallelismLowerLimit, int parallelismUpperLimit)
Computing the newParallelism. -
Uses of ShipStrategy in org.apache.flink.autoscaler.topology
Methods in org.apache.flink.autoscaler.topology that return ShipStrategy Modifier and Type Method Description static ShipStrategy
ShipStrategy. of(java.lang.String value)
Generates a ShipStrategy from a string, or returnsUNKNOWN
if the value cannot match any ShipStrategy.static ShipStrategy
ShipStrategy. valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.static ShipStrategy[]
ShipStrategy. values()
Returns an array containing the constants of this enum type, in the order they are declared.Constructor parameters in org.apache.flink.autoscaler.topology with type arguments of type ShipStrategy 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)
-