org.locationtech.geowave.format.geolife

Class GeoLifeIngestPlugin

java.lang.Object

org.locationtech.geowave.adapter.vector.ingest.AbstractSimpleFeatureIngestPlugin<AvroWholeFile>

org.locationtech.geowave.format.geolife.GeoLifeIngestPlugin

All Implemented Interfaces:

org.locationtech.geowave.core.index.persist.Persistable, GeoWaveAvroFormatPlugin<AvroWholeFile,org.opengis.feature.simple.SimpleFeature>, GeoWaveAvroPluginBase<AvroWholeFile>, GeoWaveAvroSchemaProvider, IngestFromHdfsPlugin<AvroWholeFile,org.opengis.feature.simple.SimpleFeature>, org.locationtech.geowave.core.store.ingest.DataAdapterProvider<org.opengis.feature.simple.SimpleFeature>, org.locationtech.geowave.core.store.ingest.IndexProvider, org.locationtech.geowave.core.store.ingest.IngestPluginBase<URL,org.opengis.feature.simple.SimpleFeature>, org.locationtech.geowave.core.store.ingest.LocalFileIngestPlugin<org.opengis.feature.simple.SimpleFeature>, org.locationtech.geowave.core.store.ingest.LocalPluginBase

public class GeoLifeIngestPlugin
extends AbstractSimpleFeatureIngestPlugin<AvroWholeFile>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GeoLifeIngestPlugin.IngestGeoLifeFromHdfs

Nested classes/interfaces inherited from class org.locationtech.geowave.adapter.vector.ingest.AbstractSimpleFeatureIngestPlugin

AbstractSimpleFeatureIngestPlugin.AbstractIngestSimpleFeatureWithMapper<I>

Field Summary

Fields inherited from class org.locationtech.geowave.adapter.vector.ingest.AbstractSimpleFeatureIngestPlugin

filterOptionProvider, serializationFormatOptionProvider, simpOptionProvider, typeNameProvider

Constructor Summary

Constructors

Constructor and Description
GeoLifeIngestPlugin()

Method Summary

Modifier and Type	Method and Description
org.apache.avro.Schema	getAvroSchema()
String[]	getFileExtensionFilters()
org.locationtech.geowave.core.store.ingest.IngestPluginBase<AvroWholeFile,org.opengis.feature.simple.SimpleFeature>	getIngestWithAvroPlugin()
org.locationtech.geowave.core.store.api.Index[]	getRequiredIndices()
String[]	getSupportedIndexTypes()
protected org.opengis.feature.simple.SimpleFeatureType[]	getTypes()
IngestWithMapper<AvroWholeFile,org.opengis.feature.simple.SimpleFeature>	ingestWithMapper()
IngestWithReducer<AvroWholeFile,?,?,org.opengis.feature.simple.SimpleFeature>	ingestWithReducer()
void	init(URL baseDirectory)
boolean	isUseReducerPreferred()
boolean	supportsFile(URL file)
org.locationtech.geowave.core.store.CloseableIterator<AvroWholeFile>	toAvroObjects(URL input)
protected org.locationtech.geowave.core.store.CloseableIterator<org.locationtech.geowave.core.store.ingest.GeoWaveData<org.opengis.feature.simple.SimpleFeature>>	toGeoWaveDataInternal(AvroWholeFile hfile, String[] indexNames)

Methods inherited from class org.locationtech.geowave.adapter.vector.ingest.AbstractSimpleFeatureIngestPlugin

fromBinary, getDataAdapters, newAdapter, setFilterProvider, setGeometrySimpOptionProvider, setSerializationFormatProvider, setTypeNameProvider, toBinary, toGeoWaveData, wrapIteratorWithFilters

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.store.ingest.IngestPluginBase

getDataAdapters

Constructor Detail

GeoLifeIngestPlugin

public GeoLifeIngestPlugin()

Method Detail

getTypes

protected org.opengis.feature.simple.SimpleFeatureType[] getTypes()

Specified by:

getTypes in class AbstractSimpleFeatureIngestPlugin<AvroWholeFile>

getFileExtensionFilters

public String[] getFileExtensionFilters()

init

public void init(URL baseDirectory)

supportsFile

public boolean supportsFile(URL file)

getAvroSchema

public org.apache.avro.Schema getAvroSchema()

toAvroObjects

public org.locationtech.geowave.core.store.CloseableIterator<AvroWholeFile> toAvroObjects(URL input)

isUseReducerPreferred

public boolean isUseReducerPreferred()

ingestWithMapper

public IngestWithMapper<AvroWholeFile,org.opengis.feature.simple.SimpleFeature> ingestWithMapper()

ingestWithReducer

public IngestWithReducer<AvroWholeFile,?,?,org.opengis.feature.simple.SimpleFeature> ingestWithReducer()

toGeoWaveDataInternal

protected org.locationtech.geowave.core.store.CloseableIterator<org.locationtech.geowave.core.store.ingest.GeoWaveData<org.opengis.feature.simple.SimpleFeature>> toGeoWaveDataInternal(AvroWholeFile hfile,
                                                                                                                                                                                        String[] indexNames)

Specified by:

toGeoWaveDataInternal in class AbstractSimpleFeatureIngestPlugin<AvroWholeFile>

getRequiredIndices

public org.locationtech.geowave.core.store.api.Index[] getRequiredIndices()

getIngestWithAvroPlugin

public org.locationtech.geowave.core.store.ingest.IngestPluginBase<AvroWholeFile,org.opengis.feature.simple.SimpleFeature> getIngestWithAvroPlugin()

getSupportedIndexTypes

public String[] getSupportedIndexTypes()