Interface Reconciler<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>>
-
- Type Parameters:
CR- The custom resource to be reconciled.
- All Known Implementing Classes:
AbstractFlinkResourceReconciler,AbstractJobReconciler,ApplicationReconciler,SessionJobReconciler,SessionReconciler
public interface Reconciler<CR extends org.apache.flink.kubernetes.operator.api.AbstractFlinkResource<?,?>>The interface of reconciler.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description io.javaoperatorsdk.operator.api.reconciler.DeleteControlcleanup(FlinkResourceContext<CR> context)This is called when receiving the delete event of custom resource.voidreconcile(FlinkResourceContext<CR> context)This is called when receiving the create or update event of the custom resource.
-
-
-
Method Detail
-
reconcile
void reconcile(FlinkResourceContext<CR> context) throws java.lang.Exception
This is called when receiving the create or update event of the custom resource.- Parameters:
context- the context with which the operation is executed- Throws:
java.lang.Exception- Error during reconciliation.
-
cleanup
io.javaoperatorsdk.operator.api.reconciler.DeleteControl cleanup(FlinkResourceContext<CR> context)
This is called when receiving the delete event of custom resource. This method is meant to cleanup the associated components like the Flink job components.- Parameters:
context- the context with which the operation is executed- Returns:
- DeleteControl to manage the deletion behavior
-
-