org.apache.flink.test.util

Class SQLJobSubmission

java.lang.Object

org.apache.flink.test.util.SQLJobSubmission

public class SQLJobSubmission
extends Object

Programmatic definition of a SQL job-submission.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SQLJobSubmission.ClientMode Use which client to submit job.
static class	SQLJobSubmission.SQLJobSubmissionBuilder Builder for the SQLJobSubmission.

Method Summary

Modifier and Type	Method and Description
SQLJobSubmission.ClientMode	getClientMode()
java.util.function.Consumer<Map<String,String>>	getEnvProcessor()
List<String>	getJars()
List<String>	getSqlLines()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getClientMode

public SQLJobSubmission.ClientMode getClientMode()

getJars

public List<String> getJars()

getSqlLines

public List<String> getSqlLines()

getEnvProcessor

public java.util.function.Consumer<Map<String,String>> getEnvProcessor()