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(FlinkResourceContext<?> ctx)
Called when the custom resource is deleted.void
scale(FlinkResourceContext<?> ctx)
Called as part of the reconciliation loop.
-
-
-
Method Detail
-
scale
void scale(FlinkResourceContext<?> ctx) throws java.lang.Exception
Called as part of the reconciliation loop. Returns true if this call led to scaling.- Throws:
java.lang.Exception
-
cleanup
void cleanup(FlinkResourceContext<?> ctx)
Called when the custom resource is deleted.
-
-