public class SparkCommandBuilderImpl extends InvocationCallbackBase<CommandResponse> implements SparkCommandBuilder
Modifier and Type | Method and Description |
---|---|
SparkCommandBuilder |
arguments(String arguments)
Specify the spark specific command line options which are passed on to spark-submit.
|
BaseCommand |
build() |
SparkCommandBuilder |
clusterLabel(String clusterLabel)
Specify cluster label corresponding to the cluster to be
used to run this command.
|
SparkCommandBuilder |
cmdLine(String cmdLine)
For power users, this function provides ability to provide the
spark-submit command line directly.
|
protected BaseCommand.COMMAND_TYPE |
getCommandType() |
protected com.fasterxml.jackson.databind.node.ObjectNode |
getEntity() |
protected InvokeArguments<CommandResponse> |
getInvokeArguments() |
SparkCommandBuilder |
language(String language)
Specify the language of the program, Scala, SQL, Command, R, or Python.
|
SparkCommandBuilder |
name(String commandName)
Specify a name to the command.
|
SparkCommandBuilder |
program(String program)
Set the Scala, Python, SQL or R code snippet for the SparkCommand.
|
SparkCommandBuilder |
sql(String sql)
Specify SQL query to be executed by command.
|
SparkCommandBuilder |
tags(String[] queryTags)
Specify a list of tags for the command so that it is easily identifiable and searchable
from the commands list in the Commands History.
|
SparkCommandBuilder |
userProgramArguments(String userProgramArguments)
Specify the arguments that the user program takes in.
|
getArgumentsInvocation, invoke, raw, withCallback
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getArgumentsInvocation, invoke, raw, withCallback
public SparkCommandBuilder program(String program)
SparkCommandBuilder
SparkCommandBuilder.sql(String)
method.program
in interface SparkCommandBuilder
public SparkCommandBuilder cmdLine(String cmdLine)
SparkCommandBuilder
cmdLine
in interface SparkCommandBuilder
public SparkCommandBuilder language(String language)
SparkCommandBuilder
SparkCommandBuilder.program(String)
is used.language
in interface SparkCommandBuilder
public SparkCommandBuilder sql(String sql)
SparkCommandBuilder
sql
in interface SparkCommandBuilder
public SparkCommandBuilder userProgramArguments(String userProgramArguments)
SparkCommandBuilder
userProgramArguments
in interface SparkCommandBuilder
public SparkCommandBuilder arguments(String arguments)
SparkCommandBuilder
arguments
in interface SparkCommandBuilder
public SparkCommandBuilder clusterLabel(String clusterLabel)
SparkCommandBuilder
clusterLabel
in interface SparkCommandBuilder
public SparkCommandBuilder name(String commandName)
SparkCommandBuilder
name
in interface SparkCommandBuilder
public SparkCommandBuilder tags(String[] queryTags)
SparkCommandBuilder
tags
in interface SparkCommandBuilder
protected com.fasterxml.jackson.databind.node.ObjectNode getEntity()
protected BaseCommand.COMMAND_TYPE getCommandType()
protected InvokeArguments<CommandResponse> getInvokeArguments()
getInvokeArguments
in class InvocationCallbackBase<CommandResponse>
public BaseCommand build()
Copyright © 2020. All rights reserved.