org.apache.flink.test.util

Class SQLJobSubmission.SQLJobSubmissionBuilder

java.lang.Object

org.apache.flink.test.util.SQLJobSubmission.SQLJobSubmissionBuilder

Enclosing class:

SQLJobSubmission

public static class SQLJobSubmission.SQLJobSubmissionBuilder
extends Object

Builder for the SQLJobSubmission.

Constructor Summary

Constructors

Constructor and Description
SQLJobSubmissionBuilder(List<String> sqlLines)

Method Summary

Modifier and Type	Method and Description
SQLJobSubmission.SQLJobSubmissionBuilder	addJar(Path jarFile)
SQLJobSubmission.SQLJobSubmissionBuilder	addJars(List<Path> jarFiles)
SQLJobSubmission.SQLJobSubmissionBuilder	addJars(Path... jarFiles)
SQLJobSubmission	build()
SQLJobSubmission.SQLJobSubmissionBuilder	setClientMode(SQLJobSubmission.ClientMode clientMode)
SQLJobSubmission.SQLJobSubmissionBuilder	setEnvProcessor(java.util.function.Consumer<Map<String,String>> envProcessor)

Methods inherited from class java.lang.Object

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

Constructor Detail

SQLJobSubmissionBuilder

public SQLJobSubmissionBuilder(List<String> sqlLines)

Method Detail

setClientMode

public SQLJobSubmission.SQLJobSubmissionBuilder setClientMode(SQLJobSubmission.ClientMode clientMode)

addJar

public SQLJobSubmission.SQLJobSubmissionBuilder addJar(Path jarFile)

addJars

public SQLJobSubmission.SQLJobSubmissionBuilder addJars(Path... jarFiles)

addJars

public SQLJobSubmission.SQLJobSubmissionBuilder addJars(List<Path> jarFiles)

setEnvProcessor

public SQLJobSubmission.SQLJobSubmissionBuilder setEnvProcessor(java.util.function.Consumer<Map<String,String>> envProcessor)

build

public SQLJobSubmission build()