org.locationtech.geowave.core.ingest.operations

Class LocalToKafkaCommand

java.lang.Object

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

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

org.locationtech.geowave.core.ingest.operations.LocalToKafkaCommand

All Implemented Interfaces:

Command, Operation

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

Method Summary

Modifier and Type	Method and Description
Void	computeResults(OperationParams params)
void	execute(OperationParams params) Prep the driver & run the operation.
KafkaProducerCommandLineOptions	getKafkaOptions()
LocalInputCommandLineOptions	getLocalInputOptions()
List<String>	getParameters()
IngestFormatPluginOptions	getPluginFormats()
boolean	prepare(OperationParams params) NOTE: ONLY USE THIS METHOD TO SET @PARAMETERSDELEGATE options.
boolean	runAsync() this method provides a hint to the service running the command whether it should be run asynchronously or not
void	setKafkaOptions(KafkaProducerCommandLineOptions kafkaOptions)
void	setLocalInputOptions(LocalInputCommandLineOptions localInputOptions)
void	setParameters(String fileOrDirectory)
void	setPluginFormats(IngestFormatPluginOptions pluginFormats)

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

getId, getMethod, getName, getPath, 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

LocalToKafkaCommand

public LocalToKafkaCommand()

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

runAsync

public boolean runAsync()

Description copied from class: ServiceEnabledCommand

this method provides a hint to the service running the command whether it should be run asynchronously or not

Overrides:

runAsync in class ServiceEnabledCommand<Void>

Returns:

should this method be run asynchronously

getParameters

public List<String> getParameters()

setParameters

public void setParameters(String fileOrDirectory)

getKafkaOptions

public KafkaProducerCommandLineOptions getKafkaOptions()

setKafkaOptions

public void setKafkaOptions(KafkaProducerCommandLineOptions kafkaOptions)

getLocalInputOptions

public LocalInputCommandLineOptions getLocalInputOptions()

setLocalInputOptions

public void setLocalInputOptions(LocalInputCommandLineOptions localInputOptions)

getPluginFormats

public IngestFormatPluginOptions getPluginFormats()

setPluginFormats

public void setPluginFormats(IngestFormatPluginOptions pluginFormats)

computeResults

public Void computeResults(OperationParams params)
                    throws Exception

Specified by:

computeResults in class ServiceEnabledCommand<Void>

Throws:

Exception