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, java.time.Duration timeout) Submits the given job to the cluster.
void	submitSQLJob(SQLJobSubmission job, java.time.Duration timeout) Submits the given SQL job to the cluster.

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

close, closeAsync

Method Detail

submitJob

JobController submitJob(JobSubmission job,
                        java.time.Duration timeout)
                 throws IOException

Submits the given job to the cluster.

Parameters:

job - job to submit

timeout - the maximum time to wait.

Returns:

JobController for the submitted job

Throws:

IOException

submitSQLJob

void submitSQLJob(SQLJobSubmission job,
                  java.time.Duration timeout)
           throws Exception

Submits the given SQL job to the cluster.

Parameters:

job - job to submit.

timeout - the maximum time to wait.

Throws:

IOException - if any IO error happen.

Exception