Uses of Class
org.apache.flink.kubernetes.operator.autoscaler.KubernetesJobAutoScalerContext

Packages that use KubernetesJobAutoScalerContext

Package	Description
org.apache.flink.kubernetes.operator.autoscaler
org.apache.flink.kubernetes.operator.autoscaler.state
org.apache.flink.kubernetes.operator.controller
org.apache.flink.kubernetes.operator.reconciler.deployment

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

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

Modifier and Type	Method	Description
static org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>	AutoscalerFactory.create(io.fabric8.kubernetes.client.KubernetesClient client, EventRecorder eventRecorder)

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

Modifier and Type	Method	Description
void	KubernetesAutoScalerEventHandler.handleEvent(KubernetesJobAutoScalerContext context, org.apache.flink.autoscaler.event.AutoScalerEventHandler.Type type, java.lang.String reason, java.lang.String message, java.lang.String messageKey, java.time.Duration interval)
void	KubernetesAutoScalerEventHandler.handleScalingEvent(KubernetesJobAutoScalerContext context, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,org.apache.flink.autoscaler.ScalingSummary> scalingSummaries, boolean scaled, java.time.Duration interval)
void	KubernetesScalingRealizer.realize(KubernetesJobAutoScalerContext context, java.util.Map<java.lang.String,java.lang.String> parallelismOverrides)

Uses of KubernetesJobAutoScalerContext in org.apache.flink.kubernetes.operator.autoscaler.state

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

Modifier and Type	Method	Description
void	ConfigMapStore.clearAll(KubernetesJobAutoScalerContext jobContext)
void	KubernetesAutoScalerStateStore.clearAll(KubernetesJobAutoScalerContext jobContext)
void	ConfigMapStore.flush(KubernetesJobAutoScalerContext jobContext)
void	KubernetesAutoScalerStateStore.flush(KubernetesJobAutoScalerContext jobContext)
java.util.SortedMap<java.time.Instant,org.apache.flink.autoscaler.metrics.CollectedMetrics>	KubernetesAutoScalerStateStore.getCollectedMetrics(KubernetesJobAutoScalerContext jobContext)
java.util.Map<java.lang.String,java.lang.String>	KubernetesAutoScalerStateStore.getParallelismOverrides(KubernetesJobAutoScalerContext jobContext)
java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.SortedMap<java.time.Instant,org.apache.flink.autoscaler.ScalingSummary>>	KubernetesAutoScalerStateStore.getScalingHistory(KubernetesJobAutoScalerContext jobContext)
protected java.util.Optional<java.lang.String>	ConfigMapStore.getSerializedState(KubernetesJobAutoScalerContext jobContext, java.lang.String key)
protected void	ConfigMapStore.putSerializedState(KubernetesJobAutoScalerContext jobContext, java.lang.String key, java.lang.String value)
void	KubernetesAutoScalerStateStore.removeCollectedMetrics(KubernetesJobAutoScalerContext jobContext)
void	KubernetesAutoScalerStateStore.removeParallelismOverrides(KubernetesJobAutoScalerContext jobContext)
void	KubernetesAutoScalerStateStore.removeScalingHistory(KubernetesJobAutoScalerContext jobContext)
protected void	ConfigMapStore.removeSerializedState(KubernetesJobAutoScalerContext jobContext, java.lang.String key)
void	KubernetesAutoScalerStateStore.storeCollectedMetrics(KubernetesJobAutoScalerContext jobContext, java.util.SortedMap<java.time.Instant,org.apache.flink.autoscaler.metrics.CollectedMetrics> metrics)
void	KubernetesAutoScalerStateStore.storeParallelismOverrides(KubernetesJobAutoScalerContext jobContext, java.util.Map<java.lang.String,java.lang.String> parallelismOverrides)
void	KubernetesAutoScalerStateStore.storeScalingHistory(KubernetesJobAutoScalerContext jobContext, java.util.Map<org.apache.flink.runtime.jobgraph.JobVertexID,java.util.SortedMap<java.time.Instant,org.apache.flink.autoscaler.ScalingSummary>> scalingHistory)
protected void	KubernetesAutoScalerStateStore.trimHistoryToMaxCmSize(KubernetesJobAutoScalerContext context)

Uses of KubernetesJobAutoScalerContext in org.apache.flink.kubernetes.operator.controller

Methods in org.apache.flink.kubernetes.operator.controller that return KubernetesJobAutoScalerContext

Modifier and Type	Method	Description
KubernetesJobAutoScalerContext	FlinkResourceContext.getJobAutoScalerContext()

Uses of KubernetesJobAutoScalerContext in org.apache.flink.kubernetes.operator.reconciler.deployment

Fields in org.apache.flink.kubernetes.operator.reconciler.deployment with type parameters of type KubernetesJobAutoScalerContext

Modifier and Type	Field	Description
protected org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext>	AbstractFlinkResourceReconciler.autoscaler

Constructor parameters in org.apache.flink.kubernetes.operator.reconciler.deployment with type arguments of type KubernetesJobAutoScalerContext

Constructor	Description
AbstractFlinkResourceReconciler(EventRecorder eventRecorder, StatusRecorder<CR,STATUS> statusRecorder, org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
AbstractJobReconciler(EventRecorder eventRecorder, StatusRecorder<CR,STATUS> statusRecorder, org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
ApplicationReconciler(EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> statusRecorder, org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)
ReconcilerFactory(EventRecorder eventRecorder, StatusRecorder<org.apache.flink.kubernetes.operator.api.FlinkDeployment,org.apache.flink.kubernetes.operator.api.status.FlinkDeploymentStatus> deploymentStatusRecorder, org.apache.flink.autoscaler.JobAutoScaler<io.javaoperatorsdk.operator.processing.event.ResourceID,KubernetesJobAutoScalerContext> autoscaler)