org.locationtech.geowave.analytic.spark.sparksql.operations

Class SparkSqlCommand

java.lang.Object

org.locationtech.geowave.core.cli.api.DefaultOperation

org.locationtech.geowave.core.cli.api.ServiceEnabledCommand<Void>

org.locationtech.geowave.analytic.spark.sparksql.operations.SparkSqlCommand

All Implemented Interfaces:

Command, Operation

public class SparkSqlCommand
extends ServiceEnabledCommand<Void>

Nested Class Summary

Nested classes/interfaces inherited from class org.locationtech.geowave.core.cli.api.ServiceEnabledCommand

ServiceEnabledCommand.HttpMethod

Field Summary

Fields inherited from class org.locationtech.geowave.core.cli.api.ServiceEnabledCommand

path

Constructor Summary

Constructors

Constructor and Description
SparkSqlCommand()

Method Summary

Modifier and Type	Method and Description
Void	computeResults(OperationParams params)
void	execute(OperationParams params) Execute the command, and return whether we want to continue execution
DataStorePluginOptions	getOutputStoreOptions()
List<String>	getParameters()
SparkSqlOptions	getSparkSqlOptions()
void	setOutputStoreOptions(DataStorePluginOptions outputStoreOptions)
void	setParameters(String sql)
void	setSparkSqlOptions(SparkSqlOptions sparkSqlOptions)

Methods inherited from class org.locationtech.geowave.core.cli.api.ServiceEnabledCommand

getId, getMethod, getName, getPath, runAsync, successStatusIs200

Methods inherited from class org.locationtech.geowave.core.cli.api.DefaultOperation

generateNewEncryptionToken, getGeoWaveConfigFile, getGeoWaveConfigFile, getGeoWaveConfigProperties, getGeoWaveConfigProperties, getGeoWaveConfigProperties, getGeoWaveDirectory, getSecurityTokenFile, prepare, setSecurityTokenFile, usage

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.locationtech.geowave.core.cli.api.Operation

prepare, usage

Constructor Detail

SparkSqlCommand

public SparkSqlCommand()

Method Detail

execute

public void execute(OperationParams params)
             throws Exception

Description copied from interface: Command

Execute the command, and return whether we want to continue execution

Throws:

Exception

computeResults

public Void computeResults(OperationParams params)
                    throws Exception

Specified by:

computeResults in class ServiceEnabledCommand<Void>

Throws:

Exception

getParameters

public List<String> getParameters()

setParameters

public void setParameters(String sql)

getOutputStoreOptions

public DataStorePluginOptions getOutputStoreOptions()

setOutputStoreOptions

public void setOutputStoreOptions(DataStorePluginOptions outputStoreOptions)

getSparkSqlOptions

public SparkSqlOptions getSparkSqlOptions()

setSparkSqlOptions

public void setSparkSqlOptions(SparkSqlOptions sparkSqlOptions)