Uses of Class
org.apache.flink.kubernetes.operator.autoscaler.topology.JobTopology

Packages that use JobTopology

Package	Description
org.apache.flink.kubernetes.operator.autoscaler
org.apache.flink.kubernetes.operator.autoscaler.metrics
org.apache.flink.kubernetes.operator.autoscaler.topology

Uses of JobTopology in org.apache.flink.kubernetes.operator.autoscaler

Methods in org.apache.flink.kubernetes.operator.autoscaler that return JobTopology

Modifier and Type	Method	Description
protected JobTopology	ScalingMetricCollector.getJobTopology(FlinkService flinkService, AbstractFlinkResource<?,?> cr, org.apache.flink.configuration.Configuration conf, AutoScalerInfo scalerInfo)
protected JobTopology	ScalingMetricCollector.queryJobTopology(org.apache.flink.client.program.rest.RestClusterClient<java.lang.String> restClient, org.apache.flink.api.common.JobID jobId)

Methods in org.apache.flink.kubernetes.operator.autoscaler that return types with arguments of type JobTopology

Modifier and Type	Method	Description
protected java.util.Map<io.javaoperatorsdk.operator.processing.event.ResourceID,JobTopology>	ScalingMetricCollector.getTopologies()

Methods in org.apache.flink.kubernetes.operator.autoscaler with parameters of type JobTopology

Modifier and Type	Method	Description
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<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.

Uses of JobTopology in org.apache.flink.kubernetes.operator.autoscaler.metrics

Methods in org.apache.flink.kubernetes.operator.autoscaler.metrics with parameters of type JobTopology

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)

Uses of JobTopology in org.apache.flink.kubernetes.operator.autoscaler.topology

Methods in org.apache.flink.kubernetes.operator.autoscaler.topology that return JobTopology

Modifier and Type	Method	Description
static JobTopology	JobTopology.fromJsonPlan(java.lang.String jsonPlan, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.lang.Integer> maxParallelismMap)