Uses of Class
org.apache.flink.autoscaler.tuning.ConfigChanges
-
-
Uses of ConfigChanges in org.apache.flink.autoscaler.jdbc.state
Methods in org.apache.flink.autoscaler.jdbc.state that return ConfigChanges Modifier and Type Method Description ConfigChanges
JdbcAutoScalerStateStore. getConfigChanges(Context jobContext)
Methods in org.apache.flink.autoscaler.jdbc.state with parameters of type ConfigChanges Modifier and Type Method Description void
JdbcAutoScalerStateStore. storeConfigChanges(Context jobContext, ConfigChanges configChanges)
-
Uses of ConfigChanges in org.apache.flink.autoscaler.realizer
Methods in org.apache.flink.autoscaler.realizer with parameters of type ConfigChanges Modifier and Type Method Description void
ScalingRealizer. realizeConfigOverrides(Context context, ConfigChanges configChanges)
Updates the TaskManager memory configuration. -
Uses of ConfigChanges in org.apache.flink.autoscaler.standalone.realizer
Methods in org.apache.flink.autoscaler.standalone.realizer with parameters of type ConfigChanges Modifier and Type Method Description void
RescaleApiScalingRealizer. realizeConfigOverrides(Context context, ConfigChanges configChanges)
-
Uses of ConfigChanges in org.apache.flink.autoscaler.state
Methods in org.apache.flink.autoscaler.state that return ConfigChanges Modifier and Type Method Description ConfigChanges
AutoScalerStateStore. getConfigChanges(Context jobContext)
ConfigChanges
InMemoryAutoScalerStateStore. getConfigChanges(Context jobContext)
Methods in org.apache.flink.autoscaler.state with parameters of type ConfigChanges Modifier and Type Method Description void
AutoScalerStateStore. storeConfigChanges(Context jobContext, ConfigChanges configChanges)
void
InMemoryAutoScalerStateStore. storeConfigChanges(Context jobContext, ConfigChanges configChanges)
-
Uses of ConfigChanges in org.apache.flink.autoscaler.tuning
Methods in org.apache.flink.autoscaler.tuning that return ConfigChanges Modifier and Type Method Description ConfigChanges
ConfigChanges. addOverride(java.lang.String key, java.lang.String value)
<T> ConfigChanges
ConfigChanges. addOverride(org.apache.flink.configuration.ConfigOption<T> configOption, T value)
ConfigChanges
ConfigChanges. addRemoval(org.apache.flink.configuration.ConfigOption<?> configOption)
static ConfigChanges
MemoryTuning. tuneTaskManagerMemory(JobAutoScalerContext<?> context, EvaluatedMetrics evaluatedMetrics, JobTopology jobTopology, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,ScalingSummary> scalingSummaries, AutoScalerEventHandler eventHandler)
Emits a Configuration which contains overrides for the current configuration. -
Uses of ConfigChanges in org.apache.flink.kubernetes.operator.autoscaler
Methods in org.apache.flink.kubernetes.operator.autoscaler with parameters of type ConfigChanges Modifier and Type Method Description void
KubernetesScalingRealizer. realizeConfigOverrides(KubernetesJobAutoScalerContext context, ConfigChanges configChanges)
-
Uses of ConfigChanges in org.apache.flink.kubernetes.operator.autoscaler.state
Methods in org.apache.flink.kubernetes.operator.autoscaler.state that return ConfigChanges Modifier and Type Method Description ConfigChanges
KubernetesAutoScalerStateStore. getConfigChanges(KubernetesJobAutoScalerContext jobContext)
Methods in org.apache.flink.kubernetes.operator.autoscaler.state with parameters of type ConfigChanges Modifier and Type Method Description void
KubernetesAutoScalerStateStore. storeConfigChanges(KubernetesJobAutoScalerContext jobContext, ConfigChanges overrides)
-