org.locationtech.geowave.datastore.filesystem.operations

Class FileSystemOperations

java.lang.Object

org.locationtech.geowave.datastore.filesystem.operations.FileSystemOperations

All Implemented Interfaces:

Closeable, AutoCloseable, DataStoreOperations, MapReduceDataStoreOperations

public class FileSystemOperations
extends Object
implements MapReduceDataStoreOperations, Closeable

Constructor Summary

Constructors

Constructor and Description
FileSystemOperations(FileSystemOptions options)

Method Summary

Modifier and Type	Method and Description
void	close()
RowWriter	createDataIndexWriter(InternalDataAdapter<?> adapter)
<T> Deleter<T>	createDeleter(ReaderParams<T> readerParams)
MetadataDeleter	createMetadataDeleter(MetadataType metadataType)
MetadataReader	createMetadataReader(MetadataType metadataType)
MetadataWriter	createMetadataWriter(MetadataType metadataType)
RowReader<GeoWaveRow>	createReader(DataIndexReaderParams readerParams)
<T> RowReader<T>	createReader(ReaderParams<T> readerParams)
RowReader<GeoWaveRow>	createReader(RecordReaderParams readerParams)
RowDeleter	createRowDeleter(String indexName, PersistentAdapterStore adapterStore, InternalAdapterStore internalAdapterStore, String... authorizations)
RowWriter	createWriter(Index index, InternalDataAdapter<?> adapter)
void	delete(DataIndexReaderParams readerParams)
void	deleteAll()
boolean	deleteAll(String indexName, String typeName, Short adapterId, String... additionalAuthorizations)
void	deleteRowsFromDataIndex(byte[][] dataIds, short adapterId, String typeName)
boolean	indexExists(String indexName)
boolean	mergeData(Index index, PersistentAdapterStore adapterStore, InternalAdapterStore internalAdapterStore, AdapterIndexMappingStore adapterIndexMappingStore, Integer maxRangeDecomposition)
boolean	mergeStats(DataStatisticsStore statsStore)
boolean	metadataExists(MetadataType type)

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.operations.DataStoreOperations

clearAuthorizations, ensureAuthorizations

Constructor Detail

FileSystemOperations

public FileSystemOperations(FileSystemOptions options)

Method Detail

mergeData

public boolean mergeData(Index index,
                         PersistentAdapterStore adapterStore,
                         InternalAdapterStore internalAdapterStore,
                         AdapterIndexMappingStore adapterIndexMappingStore,
                         Integer maxRangeDecomposition)

Specified by:

mergeData in interface DataStoreOperations

mergeStats

public boolean mergeStats(DataStatisticsStore statsStore)

Specified by:

mergeStats in interface DataStoreOperations

indexExists

public boolean indexExists(String indexName)
                    throws IOException

Specified by:

indexExists in interface DataStoreOperations

Throws:

IOException

metadataExists

public boolean metadataExists(MetadataType type)
                       throws IOException

Specified by:

metadataExists in interface DataStoreOperations

Throws:

IOException

deleteAll

public void deleteAll()
               throws Exception

Specified by:

deleteAll in interface DataStoreOperations

Throws:

Exception

deleteAll

public boolean deleteAll(String indexName,
                         String typeName,
                         Short adapterId,
                         String... additionalAuthorizations)

Specified by:

deleteAll in interface DataStoreOperations

createWriter

public RowWriter createWriter(Index index,
                              InternalDataAdapter<?> adapter)

Specified by:

createWriter in interface DataStoreOperations

createDataIndexWriter

public RowWriter createDataIndexWriter(InternalDataAdapter<?> adapter)

Specified by:

createDataIndexWriter in interface DataStoreOperations

createMetadataWriter

public MetadataWriter createMetadataWriter(MetadataType metadataType)

Specified by:

createMetadataWriter in interface DataStoreOperations

createMetadataReader

public MetadataReader createMetadataReader(MetadataType metadataType)

Specified by:

createMetadataReader in interface DataStoreOperations

createMetadataDeleter

public MetadataDeleter createMetadataDeleter(MetadataType metadataType)

Specified by:

createMetadataDeleter in interface DataStoreOperations

createReader

public <T> RowReader<T> createReader(ReaderParams<T> readerParams)

Specified by:

createReader in interface DataStoreOperations

createReader

public RowReader<GeoWaveRow> createReader(DataIndexReaderParams readerParams)

Specified by:

createReader in interface DataStoreOperations

createDeleter

public <T> Deleter<T> createDeleter(ReaderParams<T> readerParams)

Specified by:

createDeleter in interface DataStoreOperations

delete

public void delete(DataIndexReaderParams readerParams)

Specified by:

delete in interface DataStoreOperations

deleteRowsFromDataIndex

public void deleteRowsFromDataIndex(byte[][] dataIds,
                                    short adapterId,
                                    String typeName)

createReader

public RowReader<GeoWaveRow> createReader(RecordReaderParams readerParams)

Specified by:

createReader in interface MapReduceDataStoreOperations

createRowDeleter

public RowDeleter createRowDeleter(String indexName,
                                   PersistentAdapterStore adapterStore,
                                   InternalAdapterStore internalAdapterStore,
                                   String... authorizations)

Specified by:

createRowDeleter in interface DataStoreOperations

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable