org.apache.flink.tests.util.flink

Interface ClusterController

All Superinterfaces:

AutoCloseable, AutoCloseableAsync

public interface ClusterController
extends AutoCloseableAsync

Controller for interacting with a cluster.

Method Summary

Modifier and Type	Method and Description
JobController	submitJob(JobSubmission job) Submits the given job to the cluster.

Methods inherited from interface org.apache.flink.util.AutoCloseableAsync

close, closeAsync

Method Detail

submitJob

JobController submitJob(JobSubmission job)
                 throws IOException

Submits the given job to the cluster.

Parameters:

job - job to submit

Returns:

JobController for the submitted job

Throws:

IOException