Interface JobAutoScaler
-
- All Known Implementing Classes:
JobAutoScalerImpl
,NoopJobAutoscalerFactory
public interface JobAutoScaler
Per-job Autoscaler instance.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
cleanup(AbstractFlinkResource<?,?> cr)
Called when the custom resource is deleted.boolean
scale(FlinkResourceContext<? extends AbstractFlinkResource<?,?>> ctx)
Called as part of the reconciliation loop.
-
-
-
Method Detail
-
scale
boolean scale(FlinkResourceContext<? extends AbstractFlinkResource<?,?>> ctx)
Called as part of the reconciliation loop. Returns true if this call led to scaling.
-
cleanup
void cleanup(AbstractFlinkResource<?,?> cr)
Called when the custom resource is deleted.
-
-