Uses of Class
org.apache.flink.kubernetes.operator.autoscaler.metrics.FlinkMetric
-
Packages that use FlinkMetric Package Description org.apache.flink.kubernetes.operator.autoscaler org.apache.flink.kubernetes.operator.autoscaler.metrics -
-
Uses of FlinkMetric in org.apache.flink.kubernetes.operator.autoscaler
Methods in org.apache.flink.kubernetes.operator.autoscaler that return types with arguments of type FlinkMetric Modifier and Type Method Description protected java.util.Map<io.javaoperatorsdk.operator.processing.event.ResourceID,java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<java.lang.String,FlinkMetric>>>
ScalingMetricCollector. getAvailableVertexMetricNames()
protected java.util.Map<java.lang.String,FlinkMetric>
ScalingMetricCollector. getFilteredVertexMetricNames(org.apache.flink.client.program.rest.RestClusterClient<?> restClient, org.apache.flink.api.common.JobID jobID, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID, JobTopology topology)
Query and filter metric names for a given job vertex.protected java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>
RestApiMetricsCollector. queryAggregatedVertexMetrics(FlinkService flinkService, AbstractFlinkResource<?,?> cr, org.apache.flink.configuration.Configuration conf, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID, java.util.Map<java.lang.String,FlinkMetric> metrics)
protected java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>>
RestApiMetricsCollector. queryAllAggregatedMetrics(AbstractFlinkResource<?,?> cr, FlinkService flinkService, org.apache.flink.configuration.Configuration conf, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<java.lang.String,FlinkMetric>> filteredVertexMetricNames)
protected abstract java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>>
ScalingMetricCollector. queryAllAggregatedMetrics(AbstractFlinkResource<?,?> cr, FlinkService flinkService, org.apache.flink.configuration.Configuration conf, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<java.lang.String,FlinkMetric>> filteredVertexMetricNames)
protected java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<java.lang.String,FlinkMetric>>
ScalingMetricCollector. queryFilteredMetricNames(FlinkService flinkService, AbstractFlinkResource<?,?> cr, org.apache.flink.configuration.Configuration conf, JobTopology topology)
Query the available metric names for each job vertex.Method parameters in org.apache.flink.kubernetes.operator.autoscaler with type arguments of type FlinkMetric Modifier and Type Method Description protected java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>
RestApiMetricsCollector. queryAggregatedVertexMetrics(FlinkService flinkService, AbstractFlinkResource<?,?> cr, org.apache.flink.configuration.Configuration conf, org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID, java.util.Map<java.lang.String,FlinkMetric> metrics)
protected java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>>
RestApiMetricsCollector. queryAllAggregatedMetrics(AbstractFlinkResource<?,?> cr, FlinkService flinkService, org.apache.flink.configuration.Configuration conf, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<java.lang.String,FlinkMetric>> filteredVertexMetricNames)
protected abstract java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>>
ScalingMetricCollector. queryAllAggregatedMetrics(AbstractFlinkResource<?,?> cr, FlinkService flinkService, org.apache.flink.configuration.Configuration conf, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<java.lang.String,FlinkMetric>> filteredVertexMetricNames)
-
Uses of FlinkMetric in org.apache.flink.kubernetes.operator.autoscaler.metrics
Fields in org.apache.flink.kubernetes.operator.autoscaler.metrics with type parameters of type FlinkMetric Modifier and Type Field Description static java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>
FlinkMetric. FINISHED_METRICS
Methods in org.apache.flink.kubernetes.operator.autoscaler.metrics that return FlinkMetric Modifier and Type Method Description static FlinkMetric
FlinkMetric. valueOf(java.lang.String name)
Returns the enum constant of this type with the specified name.static FlinkMetric[]
FlinkMetric. values()
Returns an array containing the constants of this enum type, in the order they are declared.Method parameters in org.apache.flink.kubernetes.operator.autoscaler.metrics with type arguments of type FlinkMetric Modifier and Type Method Description static void
ScalingMetrics. computeDataRateMetrics(org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID, java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> flinkMetrics, java.util.Map<ScalingMetric,java.lang.Double> scalingMetrics, JobTopology topology, double lagGrowthRate, org.apache.flink.configuration.Configuration conf)
static void
ScalingMetrics. computeLagMetrics(java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> flinkMetrics, java.util.Map<ScalingMetric,java.lang.Double> scalingMetrics)
static void
ScalingMetrics. computeLoadMetrics(org.apache.flink.runtime.jobgraph.JobVertexID jobVertexID, java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> flinkMetrics, java.util.Map<ScalingMetric,java.lang.Double> scalingMetrics, org.apache.flink.configuration.Configuration conf)
static java.util.Map<Edge,java.lang.Double>
ScalingMetrics. computeOutputRatios(java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric>> flinkMetrics, JobTopology topology)
-