Uses of Class
org.apache.flink.autoscaler.metrics.CollectedMetrics
-
Packages that use CollectedMetrics Package Description org.apache.flink.autoscaler org.apache.flink.autoscaler.jdbc.state org.apache.flink.autoscaler.state org.apache.flink.kubernetes.operator.autoscaler.state -
-
Uses of CollectedMetrics in org.apache.flink.autoscaler
Methods in org.apache.flink.autoscaler that return types with arguments of type CollectedMetrics Modifier and Type Method Description protected java.util.Map<KEY,java.util.SortedMap<java.time.Instant,CollectedMetrics>>
ScalingMetricCollector. getHistories()
Method parameters in org.apache.flink.autoscaler with type arguments of type CollectedMetrics Modifier and Type Method Description protected static double
ScalingMetricEvaluator. computeBusyTimeAvg(org.apache.flink.configuration.Configuration conf, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory, org.apache.flink.runtime.jobgraph.JobVertexID vertex, int parallelism)
Compute the average busy time for the given vertex for the current metric window.protected static double
ScalingMetricEvaluator. computeEdgeDataRate(JobTopology topology, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory, org.apache.flink.runtime.jobgraph.JobVertexID from, org.apache.flink.runtime.jobgraph.JobVertexID to)
Compute how many records flow between two job vertices in the pipeline.protected static double
ScalingMetricEvaluator. computeEdgeOutputRatio(org.apache.flink.runtime.jobgraph.JobVertexID from, org.apache.flink.runtime.jobgraph.JobVertexID to, JobTopology topology, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory)
Compute the In/Out ratio between the (from, to) vertices.protected static double
ScalingMetricEvaluator. computeTrueProcessingRate(double busyTimeAvg, double inputRateAvg, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory, org.apache.flink.runtime.jobgraph.JobVertexID vertex, org.apache.flink.configuration.Configuration conf)
Compute the true processing rate for the given vertex for the current metric window.protected static java.util.Map<ScalingMetric,EvaluatedScalingMetric>
ScalingMetricEvaluator. evaluateGlobalMetrics(java.util.SortedMap<java.time.Instant,CollectedMetrics> metricHistory)
static double
ScalingMetricEvaluator. getAverage(ScalingMetric metric, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexId, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory)
static double
ScalingMetricEvaluator. getAverage(ScalingMetric metric, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexId, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory, int minElements)
static double
ScalingMetricEvaluator. getRate(ScalingMetric metric, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexId, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory)
Compute per second rate for the given accumulated metric over the metric window.protected static boolean
ScalingMetricEvaluator. isProcessingBacklog(JobTopology topology, java.util.SortedMap<java.time.Instant,CollectedMetrics> metricsHistory, org.apache.flink.configuration.Configuration conf)
-
Uses of CollectedMetrics in org.apache.flink.autoscaler.jdbc.state
Methods in org.apache.flink.autoscaler.jdbc.state that return types with arguments of type CollectedMetrics Modifier and Type Method Description java.util.SortedMap<java.time.Instant,CollectedMetrics>
JdbcAutoScalerStateStore. getCollectedMetrics(Context jobContext)
Method parameters in org.apache.flink.autoscaler.jdbc.state with type arguments of type CollectedMetrics Modifier and Type Method Description protected static java.lang.String
JdbcAutoScalerStateStore. serializeEvaluatedMetrics(java.util.SortedMap<java.time.Instant,CollectedMetrics> evaluatedMetrics)
void
JdbcAutoScalerStateStore. storeCollectedMetrics(Context jobContext, java.util.SortedMap<java.time.Instant,CollectedMetrics> metrics)
-
Uses of CollectedMetrics in org.apache.flink.autoscaler.state
Methods in org.apache.flink.autoscaler.state that return types with arguments of type CollectedMetrics Modifier and Type Method Description java.util.SortedMap<java.time.Instant,CollectedMetrics>
AutoScalerStateStore. getCollectedMetrics(Context jobContext)
java.util.SortedMap<java.time.Instant,CollectedMetrics>
InMemoryAutoScalerStateStore. getCollectedMetrics(Context jobContext)
Method parameters in org.apache.flink.autoscaler.state with type arguments of type CollectedMetrics Modifier and Type Method Description void
AutoScalerStateStore. storeCollectedMetrics(Context jobContext, java.util.SortedMap<java.time.Instant,CollectedMetrics> metrics)
void
InMemoryAutoScalerStateStore. storeCollectedMetrics(Context jobContext, java.util.SortedMap<java.time.Instant,CollectedMetrics> metrics)
-
Uses of CollectedMetrics in org.apache.flink.kubernetes.operator.autoscaler.state
Methods in org.apache.flink.kubernetes.operator.autoscaler.state that return types with arguments of type CollectedMetrics Modifier and Type Method Description java.util.SortedMap<java.time.Instant,CollectedMetrics>
KubernetesAutoScalerStateStore. getCollectedMetrics(KubernetesJobAutoScalerContext jobContext)
Method parameters in org.apache.flink.kubernetes.operator.autoscaler.state with type arguments of type CollectedMetrics Modifier and Type Method Description protected static java.lang.String
KubernetesAutoScalerStateStore. serializeEvaluatedMetrics(java.util.SortedMap<java.time.Instant,CollectedMetrics> evaluatedMetrics)
void
KubernetesAutoScalerStateStore. storeCollectedMetrics(KubernetesJobAutoScalerContext jobContext, java.util.SortedMap<java.time.Instant,CollectedMetrics> metrics)
-