org.locationtech.geowave.core.ingest.operations

Class SparkToGeoWaveCommand

java.lang.Object

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

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

org.locationtech.geowave.core.ingest.operations.SparkToGeoWaveCommand

All Implemented Interfaces:

Command, Operation

public class SparkToGeoWaveCommand
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
SparkToGeoWaveCommand()

Method Summary

Modifier and Type	Method and Description
Void	computeResults(OperationParams params)
void	execute(OperationParams params) Prep the driver & run the operation.
VisibilityOptions	getIngestOptions()
LocalInputCommandLineOptions	getLocalInputOptions()
List<String>	getParameters()
SparkCommandLineOptions	getSparkOptions()
boolean	prepare(OperationParams params) NOTE: ONLY USE THIS METHOD TO SET @PARAMETERSDELEGATE options.
void	setIngestOptions(VisibilityOptions ingestOptions)
void	setLocalInputOptions(LocalInputCommandLineOptions localInputOptions)
void	setParameters(String inputPath, String storeName, String commaSeparatedIndexes)
void	setSparkOptions(SparkCommandLineOptions sparkOptions)

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, 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

usage

Constructor Detail

SparkToGeoWaveCommand

public SparkToGeoWaveCommand()

Method Detail

prepare

public boolean prepare(OperationParams params)

Description copied from interface: Operation

NOTE: ONLY USE THIS METHOD TO SET @PARAMETERSDELEGATE options. If you throw exceptions or do validation, then it will make help/explain commands not work correctly.

Specified by:

prepare in interface Operation

Overrides:

prepare in class DefaultOperation

execute

public void execute(OperationParams params)
             throws Exception

Prep the driver & run the operation.

Throws:

Exception

getParameters

public List<String> getParameters()

setParameters

public void setParameters(String inputPath,
                          String storeName,
                          String commaSeparatedIndexes)

getIngestOptions

public VisibilityOptions getIngestOptions()

setIngestOptions

public void setIngestOptions(VisibilityOptions ingestOptions)

getSparkOptions

public SparkCommandLineOptions getSparkOptions()

setSparkOptions

public void setSparkOptions(SparkCommandLineOptions sparkOptions)

getLocalInputOptions

public LocalInputCommandLineOptions getLocalInputOptions()

setLocalInputOptions

public void setLocalInputOptions(LocalInputCommandLineOptions localInputOptions)

computeResults

public Void computeResults(OperationParams params)
                    throws Exception

Specified by:

computeResults in class ServiceEnabledCommand<Void>

Throws:

Exception