org.locationtech.geowave.core.ingest.local

Class LocalFileIngestCLIDriver

java.lang.Object

org.locationtech.geowave.core.store.ingest.AbstractLocalFileDriver<LocalFileIngestPlugin<?>,LocalIngestRunData>

org.locationtech.geowave.core.store.ingest.AbstractLocalFileIngestDriver

org.locationtech.geowave.core.ingest.local.LocalFileIngestCLIDriver

public class LocalFileIngestCLIDriver
extends AbstractLocalFileIngestDriver

This extends the local file driver to directly ingest data into GeoWave utilizing the LocalFileIngestPlugin's that are discovered by the system.

Field Summary

Fields

Modifier and Type	Field and Description
protected List<Index>	indices
protected Map<String,LocalFileIngestPlugin<?>>	ingestPlugins
protected DataStorePluginOptions	storeOptions
protected int	threads
protected VisibilityOptions	visibilityOptions

Fields inherited from class org.locationtech.geowave.core.store.ingest.AbstractLocalFileIngestDriver

ingestExecutor

Fields inherited from class org.locationtech.geowave.core.store.ingest.AbstractLocalFileDriver

configProperties, localInput

Constructor Summary

Constructors

Constructor and Description
LocalFileIngestCLIDriver(DataStorePluginOptions storeOptions, List<Index> indices, Map<String,LocalFileIngestPlugin<?>> ingestPlugins, VisibilityOptions visibilityOptions, LocalInputCommandLineOptions inputOptions, int threads)

Method Summary

Modifier and Type	Method and Description
protected DataStore	getDataStore()
protected Map<String,Index>	getIndices()
protected Map<String,LocalFileIngestPlugin<?>>	getIngestPlugins()
protected int	getNumThreads()
protected VisibilityHandler	getVisibilityHandler()
protected boolean	isSupported(String providerName, DataAdapterProvider<?> adapterProvider)

Methods inherited from class org.locationtech.geowave.core.store.ingest.AbstractLocalFileIngestDriver

processFile, processFileMultiThreaded, processFileSingleThreaded, runOperation, shutdownExecutor, startExecutor, write

Methods inherited from class org.locationtech.geowave.core.store.ingest.AbstractLocalFileDriver

checkIndexesAgainstProvider, getExtensions, isCompatible, processInput

Methods inherited from class java.lang.Object

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

Field Detail

storeOptions

protected DataStorePluginOptions storeOptions

indices

protected List<Index> indices

visibilityOptions

protected VisibilityOptions visibilityOptions

ingestPlugins

protected Map<String,LocalFileIngestPlugin<?>> ingestPlugins

threads

protected int threads

Constructor Detail

LocalFileIngestCLIDriver

public LocalFileIngestCLIDriver(DataStorePluginOptions storeOptions,
                                List<Index> indices,
                                Map<String,LocalFileIngestPlugin<?>> ingestPlugins,
                                VisibilityOptions visibilityOptions,
                                LocalInputCommandLineOptions inputOptions,
                                int threads)

Method Detail

getIndices

protected Map<String,Index> getIndices()
                                throws IOException

Specified by:

getIndices in class AbstractLocalFileIngestDriver

Throws:

IOException

isSupported

protected boolean isSupported(String providerName,
                              DataAdapterProvider<?> adapterProvider)

Specified by:

isSupported in class AbstractLocalFileIngestDriver

getNumThreads

protected int getNumThreads()

Specified by:

getNumThreads in class AbstractLocalFileIngestDriver

getVisibilityHandler

protected VisibilityHandler getVisibilityHandler()

Specified by:

getVisibilityHandler in class AbstractLocalFileIngestDriver

getIngestPlugins

protected Map<String,LocalFileIngestPlugin<?>> getIngestPlugins()

Specified by:

getIngestPlugins in class AbstractLocalFileIngestDriver

getDataStore

protected DataStore getDataStore()

Specified by:

getDataStore in class AbstractLocalFileIngestDriver