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,org.apache.flink.api.java.tuple.Tuple2<java.lang.Long,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, org.apache.flink.configuration.Configuration conf)
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 for the current spec generation.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
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, java.util.Optional<java.lang.Double> lagGrowthOpt, 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(java.util.Map<FlinkMetric,org.apache.flink.runtime.rest.messages.job.metrics.AggregatedMetric> flinkMetrics, java.util.Map<ScalingMetric,java.lang.Double> scalingMetrics)
-