Package org.apache.flink.runtime.dispatcher.cleanup

Interface CleanupRunnerFactory

All Known Implementing Classes:

CheckpointResourcesCleanupRunnerFactory

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface CleanupRunnerFactory

CleanupRunnerFactory provides a factory method for creating CheckpointResourcesCleanupRunner instances.

Method Summary

Modifier and Type	Method	Description
JobManagerRunner	create(JobResult jobResult, CheckpointRecoveryFactory checkpointRecoveryFactory, Configuration configuration, Executor cleanupExecutor)

Method Detail

create

JobManagerRunner create(JobResult jobResult,
                        CheckpointRecoveryFactory checkpointRecoveryFactory,
                        Configuration configuration,
                        Executor cleanupExecutor)