org.locationtech.geowave.adapter.vector.plugin.transaction

Class GeoWaveTransactionManagement

java.lang.Object

org.locationtech.geowave.adapter.vector.plugin.transaction.AbstractTransactionManagement

org.locationtech.geowave.adapter.vector.plugin.transaction.GeoWaveTransactionManagement

All Implemented Interfaces:

GeoWaveTransaction

public class GeoWaveTransactionManagement
extends AbstractTransactionManagement
implements GeoWaveTransaction

Captures changes made to a FeatureStore prior to being committed.

This is used to simulate the functionality of a database including transaction independence.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOGGER

Fields inherited from class org.locationtech.geowave.adapter.vector.plugin.transaction.AbstractTransactionManagement

components

Constructor Summary

Constructors

Constructor and Description
GeoWaveTransactionManagement(int maxAdditionBufferSize, GeoWaveDataStoreComponents components, String typeName, org.geotools.data.Transaction transaction, LockingManagement lockingManager, String txID) Create an empty Diff

Method Summary

Modifier and Type	Method and Description
void	add(String fid, org.opengis.feature.simple.SimpleFeature feature)
void	clear() Clear diff - called during rollback.
void	commit()
String[]	composeAuthorizations()
String	composeVisibility()
void	flush() Flush in memory records to store for query processing.
StatisticsCache	getDataStatistics()
String	getID()
CloseableIterator<org.opengis.feature.simple.SimpleFeature>	interweaveTransaction(Integer limit, org.opengis.filter.Filter filter, CloseableIterator<org.opengis.feature.simple.SimpleFeature> it)
boolean	isEmpty() Check if modifiedFeatures and addedFeatures are empty.
void	modify(String fid, org.opengis.feature.simple.SimpleFeature original, org.opengis.feature.simple.SimpleFeature updated) Record a modification to the indicated feature ID.
void	remove(String fid, org.opengis.feature.simple.SimpleFeature feature)
void	rollback()

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static final org.slf4j.Logger LOGGER

Constructor Detail

GeoWaveTransactionManagement

public GeoWaveTransactionManagement(int maxAdditionBufferSize,
                                    GeoWaveDataStoreComponents components,
                                    String typeName,
                                    org.geotools.data.Transaction transaction,
                                    LockingManagement lockingManager,
                                    String txID)
                             throws IOException

Create an empty Diff

Throws:

IOException

Method Detail

isEmpty

public boolean isEmpty()

Check if modifiedFeatures and addedFeatures are empty.

Specified by:

isEmpty in interface GeoWaveTransaction

Returns:

true if Diff is empty

clear

public void clear()

Clear diff - called during rollback.

modify

public void modify(String fid,
                   org.opengis.feature.simple.SimpleFeature original,
                   org.opengis.feature.simple.SimpleFeature updated)
            throws IOException

Record a modification to the indicated feature ID.

Specified by:

modify in interface GeoWaveTransaction

Parameters:

fid - the feature ID

original - original feature

updated - replacement feature; null to indicate remove

Throws:

IOException

add

public void add(String fid,
                org.opengis.feature.simple.SimpleFeature feature)
         throws IOException

Specified by:

add in interface GeoWaveTransaction

Throws:

IOException

remove

public void remove(String fid,
                   org.opengis.feature.simple.SimpleFeature feature)
            throws IOException

Specified by:

remove in interface GeoWaveTransaction

Throws:

IOException

rollback

public void rollback()
              throws IOException

Throws:

IOException

composeAuthorizations

public String[] composeAuthorizations()

Specified by:

composeAuthorizations in interface GeoWaveTransaction

composeVisibility

public String composeVisibility()

Specified by:

composeVisibility in interface GeoWaveTransaction

getID

public String getID()

flush

public void flush()
           throws IOException

Description copied from interface: GeoWaveTransaction

Flush in memory records to store for query processing.

Specified by:

flush in interface GeoWaveTransaction

Throws:

IOException

commit

public void commit()
            throws IOException

Throws:

IOException

getDataStatistics

public StatisticsCache getDataStatistics()

Specified by:

getDataStatistics in interface GeoWaveTransaction

Overrides:

getDataStatistics in class AbstractTransactionManagement

interweaveTransaction

public CloseableIterator<org.opengis.feature.simple.SimpleFeature> interweaveTransaction(Integer limit,
                                                                                         org.opengis.filter.Filter filter,
                                                                                         CloseableIterator<org.opengis.feature.simple.SimpleFeature> it)

Specified by:

interweaveTransaction in interface GeoWaveTransaction