org.locationtech.geowave.datastore.kudu.operations

Class KuduOperations

java.lang.Object

org.locationtech.geowave.datastore.kudu.operations.KuduOperations

All Implemented Interfaces:

DataStoreOperations, MapReduceDataStoreOperations

public class KuduOperations
extends Object
implements MapReduceDataStoreOperations

Field Summary

Fields

Modifier and Type	Field and Description
protected KuduRequiredOptions	options

Constructor Summary

Constructors

Constructor and Description
KuduOperations(KuduRequiredOptions options)

Method Summary

Modifier and Type	Method and Description
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)
org.apache.kudu.client.AsyncKuduScanner.AsyncKuduScannerBuilder	getAsyncScannerBuilder(org.apache.kudu.client.KuduTable table)
List<org.apache.kudu.client.Delete>	getDeletions(org.apache.kudu.client.KuduTable table, List<org.apache.kudu.client.KuduPredicate> predicates, java.util.function.Function<org.apache.kudu.client.RowResult,PersistentKuduRow> adapter)
<T> KuduDataIndexRead<T>	getKuduDataIndexRead(String indexName, short adapterId, byte[][] dataIds, java.util.function.Predicate<GeoWaveRow> rowFilter, boolean visibilityEnabled)
String	getKuduQualifiedName(String name)
<T> KuduRangeRead<T>	getKuduRangeRead(String indexName, short[] adapterIds, Collection<SinglePartitionQueryRanges> ranges, boolean rowMerging, GeoWaveRowIteratorTransformer<T> rowTransformer, java.util.function.Predicate<GeoWaveRow> rowFilter, boolean visibilityEnabled)
String	getMetadataTableName(MetadataType metadataType)
org.apache.kudu.client.KuduScanner.KuduScannerBuilder	getScannerBuilder(org.apache.kudu.client.KuduTable table)
org.apache.kudu.client.KuduSession	getSession()
org.apache.kudu.client.KuduTable	getTable(String tableName)
boolean	indexExists(String indexName)
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, mergeData, mergeStats

Field Detail

options

protected final KuduRequiredOptions options

Constructor Detail

KuduOperations

public KuduOperations(KuduRequiredOptions options)

Method Detail

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(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

createReader

public RowReader<GeoWaveRow> createReader(DataIndexReaderParams readerParams)

Specified by:

createReader in interface DataStoreOperations

delete

public void delete(DataIndexReaderParams readerParams)

Specified by:

delete in interface DataStoreOperations

getKuduRangeRead

public <T> KuduRangeRead<T> getKuduRangeRead(String indexName,
                                             short[] adapterIds,
                                             Collection<SinglePartitionQueryRanges> ranges,
                                             boolean rowMerging,
                                             GeoWaveRowIteratorTransformer<T> rowTransformer,
                                             java.util.function.Predicate<GeoWaveRow> rowFilter,
                                             boolean visibilityEnabled)
                                      throws org.apache.kudu.client.KuduException

Throws:

org.apache.kudu.client.KuduException

createDeleter

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

Specified by:

createDeleter in interface DataStoreOperations

getKuduDataIndexRead

public <T> KuduDataIndexRead<T> getKuduDataIndexRead(String indexName,
                                                     short adapterId,
                                                     byte[][] dataIds,
                                                     java.util.function.Predicate<GeoWaveRow> rowFilter,
                                                     boolean visibilityEnabled)
                                              throws org.apache.kudu.client.KuduException

Throws:

org.apache.kudu.client.KuduException

getScannerBuilder

public org.apache.kudu.client.KuduScanner.KuduScannerBuilder getScannerBuilder(org.apache.kudu.client.KuduTable table)

getAsyncScannerBuilder

public org.apache.kudu.client.AsyncKuduScanner.AsyncKuduScannerBuilder getAsyncScannerBuilder(org.apache.kudu.client.KuduTable table)

getTable

public org.apache.kudu.client.KuduTable getTable(String tableName)
                                          throws org.apache.kudu.client.KuduException

Throws:

org.apache.kudu.client.KuduException

getSession

public org.apache.kudu.client.KuduSession getSession()

getKuduQualifiedName

public String getKuduQualifiedName(String name)

getMetadataTableName

public String getMetadataTableName(MetadataType metadataType)

getDeletions

public List<org.apache.kudu.client.Delete> getDeletions(org.apache.kudu.client.KuduTable table,
                                                        List<org.apache.kudu.client.KuduPredicate> predicates,
                                                        java.util.function.Function<org.apache.kudu.client.RowResult,PersistentKuduRow> adapter)
                                                 throws org.apache.kudu.client.KuduException

Throws:

org.apache.kudu.client.KuduException