org.locationtech.geowave.core.store.ingest

Class LocalIngestRunData.IndexWriterFactory

java.lang.Object

org.apache.commons.pool2.BaseKeyedPooledObjectFactory<org.locationtech.geowave.core.store.ingest.LocalIngestRunData.TypeNameKeyWithIndices,Writer>

org.locationtech.geowave.core.store.ingest.LocalIngestRunData.IndexWriterFactory

All Implemented Interfaces:

org.apache.commons.pool2.KeyedPooledObjectFactory<org.locationtech.geowave.core.store.ingest.LocalIngestRunData.TypeNameKeyWithIndices,Writer>

Enclosing class:

LocalIngestRunData

public class LocalIngestRunData.IndexWriterFactory
extends org.apache.commons.pool2.BaseKeyedPooledObjectFactory<org.locationtech.geowave.core.store.ingest.LocalIngestRunData.TypeNameKeyWithIndices,Writer>

A factory implementing the default Apache Commons Pool interface to return new instances of an index writer for a given primary index.

Constructor Summary

Constructors

Constructor and Description
IndexWriterFactory()

Method Summary

Modifier and Type	Method and Description
Writer<?>	create(org.locationtech.geowave.core.store.ingest.LocalIngestRunData.TypeNameKeyWithIndices adapterWithIndices)
void	destroyObject(org.locationtech.geowave.core.store.ingest.LocalIngestRunData.TypeNameKeyWithIndices key, org.apache.commons.pool2.PooledObject<Writer> p)
org.apache.commons.pool2.PooledObject<Writer>	wrap(Writer writer)

Methods inherited from class org.apache.commons.pool2.BaseKeyedPooledObjectFactory

activateObject, makeObject, passivateObject, validateObject

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexWriterFactory

public IndexWriterFactory()

Method Detail

create

public Writer<?> create(org.locationtech.geowave.core.store.ingest.LocalIngestRunData.TypeNameKeyWithIndices adapterWithIndices)
                 throws Exception

Specified by:

create in class org.apache.commons.pool2.BaseKeyedPooledObjectFactory<org.locationtech.geowave.core.store.ingest.LocalIngestRunData.TypeNameKeyWithIndices,Writer>

Throws:

Exception

destroyObject

public void destroyObject(org.locationtech.geowave.core.store.ingest.LocalIngestRunData.TypeNameKeyWithIndices key,
                          org.apache.commons.pool2.PooledObject<Writer> p)
                   throws Exception

Specified by:

destroyObject in interface org.apache.commons.pool2.KeyedPooledObjectFactory<org.locationtech.geowave.core.store.ingest.LocalIngestRunData.TypeNameKeyWithIndices,Writer>

Overrides:

destroyObject in class org.apache.commons.pool2.BaseKeyedPooledObjectFactory<org.locationtech.geowave.core.store.ingest.LocalIngestRunData.TypeNameKeyWithIndices,Writer>

Throws:

Exception

wrap

public org.apache.commons.pool2.PooledObject<Writer> wrap(Writer writer)

Specified by:

wrap in class org.apache.commons.pool2.BaseKeyedPooledObjectFactory<org.locationtech.geowave.core.store.ingest.LocalIngestRunData.TypeNameKeyWithIndices,Writer>