Modifier and Type | Method and Description |
---|---|
Mergeable |
RasterTileRowTransform.getRowAsMergeableObject(short internalAdapterId,
ByteArray fieldId,
byte[] rowValueBinary) |
Modifier and Type | Method and Description |
---|---|
ByteArray |
CQLDelete.StringToByteArrayConverter.convert(String value) |
Modifier and Type | Field and Description |
---|---|
protected Map<ByteArray,StatisticValue<?>> |
StatisticsCache.cache |
Modifier and Type | Method and Description |
---|---|
ByteArray |
SimpleFeatureWrapper.getInsertionId() |
Constructor and Description |
---|
SimpleFeatureWrapper(org.opengis.feature.simple.SimpleFeature simpleFeature,
ByteArray insertionId,
int subStratIdx) |
Modifier and Type | Method and Description |
---|---|
ByteArray |
AdapterWithObjectWritable.getDataId() |
Modifier and Type | Method and Description |
---|---|
static void |
AdapterWithObjectWritable.fillWritableWithAdapter(HadoopWritableSerializationTool serializationTool,
AdapterWithObjectWritable writableToFill,
short internalAdapterId,
ByteArray dataId,
Object entry) |
void |
AdapterWithObjectWritable.setDataId(ByteArray dataId) |
Modifier and Type | Method and Description |
---|---|
ByteArray |
NeighborData.getId() |
Modifier and Type | Method and Description |
---|---|
protected void |
NeighborData.setId(ByteArray id) |
Constructor and Description |
---|
NeighborData(T element,
ByteArray id,
double distance) |
Modifier and Type | Field and Description |
---|---|
protected Map<ByteArray,Cluster> |
DBScanClusterList.index |
Modifier and Type | Method and Description |
---|---|
ByteArray |
DBScanClusterList.getId() |
ByteArray |
Cluster.getId() |
Modifier and Type | Method and Description |
---|---|
protected Map<ByteArray,Cluster> |
DBScanMapReduce.DBScanMapReducer.createSummary() |
protected List<ByteArray> |
DBScanClusterList.getIds(boolean allowUpdates) |
Map<ByteArray,Cluster> |
ClusterNeighborList.ClusterNeighborListFactory.getIndex() |
Set<ByteArray> |
DBScanClusterList.getLinkedClusters() |
Set<ByteArray> |
Cluster.getLinkedClusters() |
protected Set<ByteArray> |
DBScanClusterList.getLinkedClusters(boolean allowUpdates) |
Iterator<Map.Entry<ByteArray,ClusterItem>> |
DBScanClusterList.iterator() |
Iterator<Map.Entry<ByteArray,ClusterItem>> |
ClusterNeighborList.iterator() |
Modifier and Type | Method and Description |
---|---|
boolean |
DBScanClusterList.add(DistanceProfile<?> distanceProfile,
ByteArray newId,
ClusterItem newInstance) |
boolean |
ClusterNeighborList.add(DistanceProfile<?> distanceProfile,
ByteArray id,
ClusterItem value) |
protected abstract long |
DBScanClusterList.addAndFetchCount(ByteArray newId,
ClusterItem newInstance,
DistanceProfile<?> distanceProfile) |
protected long |
SingleItemClusterList.addAndFetchCount(ByteArray id,
ClusterItem newInstance,
DistanceProfile<?> distanceProfile) |
protected long |
ClusterUnionList.addAndFetchCount(ByteArray id,
ClusterItem newInstance,
DistanceProfile<?> distanceProfile) |
NeighborList<ClusterItem> |
SingleItemClusterList.SingleItemClusterListFactory.buildNeighborList(ByteArray centerId,
ClusterItem center) |
NeighborList<ClusterItem> |
PreProcessSingleItemClusterList.PreProcessSingleItemClusterListFactory.buildNeighborList(ByteArray centerId,
ClusterItem center) |
NeighborList<ClusterItem> |
ClusterUnionList.ClusterUnionListFactory.buildNeighborList(ByteArray centerId,
ClusterItem center) |
NeighborList<ClusterItem> |
ClusterNeighborList.ClusterNeighborListFactory.buildNeighborList(ByteArray centerId,
ClusterItem center) |
ClusterItem |
DBScanMapReduce.SimpleFeatureToClusterItemConverter.convert(ByteArray id,
Object o) |
NeighborList.InferType |
DBScanClusterList.infer(ByteArray id,
ClusterItem value) |
NeighborList.InferType |
ClusterNeighborList.infer(ByteArray id,
ClusterItem value) |
protected void |
DBScanMapReduce.DBScanMapReducer.processNeighbors(Partitioner.PartitionData partitionData,
ByteArray primaryId,
ClusterItem primary,
NeighborList<ClusterItem> neighbors,
org.apache.hadoop.mapreduce.Reducer.Context context,
Map<ByteArray,Cluster> index) |
Modifier and Type | Method and Description |
---|---|
NeighborListFactory<ClusterItem> |
DBScanMapReduce.DBScanMapHullReducer.createNeighborsListFactory(Map<ByteArray,Cluster> summary) |
protected void |
DBScanMapReduce.DBScanMapHullReducer.preprocess(org.apache.hadoop.mapreduce.Reducer.Context context,
NNProcessor<Object,ClusterItem> processor,
Map<ByteArray,Cluster> index)
Find the large clusters and condense them down.
|
protected void |
DBScanMapReduce.DBScanMapReducer.processNeighbors(Partitioner.PartitionData partitionData,
ByteArray primaryId,
ClusterItem primary,
NeighborList<ClusterItem> neighbors,
org.apache.hadoop.mapreduce.Reducer.Context context,
Map<ByteArray,Cluster> index) |
protected void |
DBScanMapReduce.DBScanMapHullReducer.processSummary(Partitioner.PartitionData partitionData,
Map<ByteArray,Cluster> summary,
org.apache.hadoop.mapreduce.Reducer.Context context) |
Constructor and Description |
---|
ClusterNeighborList(ByteArray centerId,
ClusterItem center,
NeighborListFactory<ClusterItem> factory,
Map<ByteArray,Cluster> index) |
ClusterUnionList(ByteArray centerId,
ClusterItem center,
NeighborListFactory<ClusterItem> factory,
Map<ByteArray,Cluster> index) |
DBScanClusterList(org.locationtech.jts.geom.Geometry clusterGeo,
int itemCount,
ByteArray centerId,
Map<ByteArray,Cluster> index) |
PreProcessSingleItemClusterList(ByteArray centerId,
ClusterItem center,
NeighborListFactory<ClusterItem> factory,
Map<ByteArray,Cluster> index) |
SingleItemClusterList(ByteArray centerId,
ClusterItem center,
NeighborListFactory<ClusterItem> factory,
Map<ByteArray,Cluster> index) |
Modifier and Type | Method and Description |
---|---|
protected void |
NNMapReduce.NNSimpleFeatureIDOutputReducer.processNeighbors(Partitioner.PartitionData partitionData,
ByteArray primaryId,
org.opengis.feature.simple.SimpleFeature primary,
NeighborList<org.opengis.feature.simple.SimpleFeature> neighbors,
org.apache.hadoop.mapreduce.Reducer.Context context,
Boolean summary) |
protected abstract void |
NNMapReduce.NNReducer.processNeighbors(Partitioner.PartitionData partitionData,
ByteArray primaryId,
VALUEIN primary,
NeighborList<VALUEIN> neighbors,
org.apache.hadoop.mapreduce.Reducer.Context context,
PARTITION_SUMMARY summary) |
Modifier and Type | Field and Description |
---|---|
protected ByteArray |
NNProcessor.startingPoint
Run State
|
Modifier and Type | Method and Description |
---|---|
Iterator<Map.Entry<ByteArray,NNTYPE>> |
NullList.iterator() |
Iterator<Map.Entry<ByteArray,NNTYPE>> |
DefaultNeighborList.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
NNProcessor.add(ByteArray id,
boolean isPrimary,
PARTITION_VALUE partitionValue) |
boolean |
NeighborList.add(DistanceProfile<?> distanceProfile,
ByteArray id,
NNTYPE value)
May be called prior to init() when discovered by entry itself.
|
boolean |
NullList.add(DistanceProfile<?> distanceProfile,
ByteArray id,
NNTYPE value) |
boolean |
DefaultNeighborList.add(DistanceProfile<?> distanceProfile,
ByteArray id,
NNTYPE value) |
void |
NeighborIndex.add(DistanceProfile<?> distanceProfile,
ByteArray centerId,
NNTYPE centerValue,
ByteArray neighborId,
NNTYPE neighborValue,
boolean addReciprical) |
NeighborList<NNTYPE> |
DefaultNeighborList.DefaultNeighborListFactory.buildNeighborList(ByteArray centerId,
NNTYPE center) |
NeighborList<NNTYPE> |
NeighborListFactory.buildNeighborList(ByteArray cnterId,
NNTYPE center) |
void |
NNProcessor.CompleteNotifier.complete(ByteArray id,
STORE_VALUE value,
NeighborList<STORE_VALUE> list) |
TYPE |
TypeConverter.convert(ByteArray id,
Object o) |
void |
NeighborIndex.empty(ByteArray id) |
NNTYPE |
DefaultNeighborList.get(ByteArray key) |
NeighborList.InferType |
NeighborList.infer(ByteArray id,
NNTYPE value)
See if the entries relationships have already been inferred
|
NeighborList.InferType |
NullList.infer(ByteArray id,
NNTYPE value) |
NeighborList.InferType |
DefaultNeighborList.infer(ByteArray id,
NNTYPE value) |
NeighborList<NNTYPE> |
NeighborIndex.init(ByteArray id,
NNTYPE value)
Invoked when the provided node is being inspected to find neighbors.
|
void |
NNProcessor.remove(ByteArray id) |
Modifier and Type | Method and Description |
---|---|
ByteArray |
Partitioner.PartitionData.getCompositeKey() |
ByteArray |
Partitioner.PartitionData.getGroupId() |
ByteArray |
Partitioner.PartitionData.getPartitionKey() |
ByteArray |
Partitioner.PartitionData.getSortKey() |
Modifier and Type | Method and Description |
---|---|
void |
Partitioner.PartitionData.setGroupId(ByteArray groupId) |
Constructor and Description |
---|
PartitionData(ByteArray partitionKey,
ByteArray sortKey,
boolean primary) |
Modifier and Type | Method and Description |
---|---|
org.apache.spark.api.java.JavaPairRDD<ByteArray,scala.Tuple2<GeoWaveInputKey,org.opengis.feature.simple.SimpleFeature>> |
GeoWaveIndexedRDD.getIndexedFeatureRDD() |
org.apache.spark.api.java.JavaPairRDD<ByteArray,scala.Tuple2<GeoWaveInputKey,org.opengis.feature.simple.SimpleFeature>> |
GeoWaveIndexedRDD.getIndexedFeatureRDD(double bufferAmount) |
org.apache.spark.api.java.JavaPairRDD<ByteArray,scala.Tuple2<GeoWaveInputKey,org.locationtech.jts.geom.Geometry>> |
GeoWaveIndexedRDD.getIndexedGeometryRDD() |
org.apache.spark.api.java.JavaPairRDD<ByteArray,scala.Tuple2<GeoWaveInputKey,org.locationtech.jts.geom.Geometry>> |
GeoWaveIndexedRDD.getIndexedGeometryRDD(double bufferAmount,
boolean recalculate) |
Modifier and Type | Method and Description |
---|---|
ByteArray |
AbstractGeoWaveQuery.StringToByteArrayConverter.convert(String value) |
Modifier and Type | Method and Description |
---|---|
ByteArray[] |
SpatialBinningType.getSpatialBins(org.locationtech.jts.geom.Geometry geometry,
int precision) |
Modifier and Type | Method and Description |
---|---|
org.locationtech.jts.geom.Geometry |
SpatialBinningType.getBinGeometry(ByteArray bin,
int precision) |
Modifier and Type | Method and Description |
---|---|
<I> ByteArray[] |
SpatialBinningStrategy.getBins(DataTypeAdapter<I> adapter,
I entry,
GeoWaveRow... rows)
calculates appropriate bins for a given entry.
|
Modifier and Type | Method and Description |
---|---|
<T> ByteArray[] |
SpatialFieldValueBinningStrategy.getBins(DataTypeAdapter<T> adapter,
T entry,
GeoWaveRow... rows) |
protected ByteArray |
TimeRangeFieldValueBinningStrategy.getSingleBin(Object value) |
protected ByteArray[] |
SpatialFieldValueBinningStrategy.getSpatialBins(org.locationtech.jts.geom.Geometry geometry) |
Modifier and Type | Method and Description |
---|---|
String |
TimeRangeFieldValueBinningStrategy.binToString(ByteArray bin) |
String |
SpatialFieldValueBinningStrategy.binToString(ByteArray bin) |
org.threeten.extra.Interval |
TimeRangeFieldValueBinningStrategy.getInterval(ByteArray binId) |
<T> double |
SpatialFieldValueBinningStrategy.getWeight(ByteArray bin,
DataTypeAdapter<T> type,
T entry,
GeoWaveRow... rows) |
Modifier and Type | Method and Description |
---|---|
static ByteArray[] |
ByteArray.fromBytes(byte[] idData) |
Modifier and Type | Method and Description |
---|---|
int |
ByteArray.compareTo(ByteArray o) |
static byte[] |
ByteArray.toBytes(ByteArray[] ids) |
Modifier and Type | Method and Description |
---|---|
ByteArray |
AdapterMapping.getAdapterId() |
Constructor and Description |
---|
AdapterMapping(ByteArray adapterId,
short internalAdapterId) |
Modifier and Type | Method and Description |
---|---|
M |
RowMergingDataAdapter.RowTransform.getRowAsMergeableObject(short internalAdapterId,
ByteArray fieldId,
byte[] rowValueBinary) |
M |
SimpleRowTransform.getRowAsMergeableObject(short internalAdapterId,
ByteArray fieldId,
byte[] rowValueBinary) |
Modifier and Type | Field and Description |
---|---|
protected ByteArray |
StatisticValue.bin |
static ByteArray |
StatisticValue.NO_BIN |
Modifier and Type | Method and Description |
---|---|
static ByteArray |
IndexStatistic.generateGroupId(String indexName) |
static ByteArray |
DataTypeStatistic.generateGroupId(String typeName) |
static ByteArray |
FieldStatistic.generateGroupId(String typeName) |
ByteArray |
StatisticValue.getBin()
Gets the bin for this value.
|
ByteArray[] |
BinConstraints.ByteArrayConstraints.getBins()
get the bins to query for
|
<T> ByteArray[] |
BinningStrategy.getBins(DataTypeAdapter<T> type,
T entry,
GeoWaveRow... rows)
Get the bins used by the given entry.
|
Modifier and Type | Method and Description |
---|---|
AggregationQuery<BinningAggregationOptions<P,T>,Map<ByteArray,R>,T> |
AggregationQueryBuilder.buildWithBinningStrategy(BinningStrategy binningStrategy,
int maxBins)
Instead of having a scalar aggregation, bin the results by a given strategy.
|
static IndexStatisticQueryBuilder<FieldVisibilityCountStatistic.FieldVisibilityCountValue,Map<ByteArray,Long>> |
StatisticQueryBuilder.fieldVisibilityCount()
Create a new index statistic query builder for a field visibility count statistic.
|
default <V extends StatisticValue<R>,R> |
DataStore.getBinnedStatisticValues(Statistic<V> stat)
Returns all of the statistic values of this stat as well as the associated bin.
|
<V extends StatisticValue<R>,R> |
DataStore.getBinnedStatisticValues(Statistic<V> stat,
BinConstraints binConstraints)
The statistic values of this stat as well as the associated bin.
|
static IndexStatisticQueryBuilder<PartitionsStatistic.PartitionsValue,Set<ByteArray>> |
StatisticQueryBuilder.partitions()
Create a new index statistic query builder for a partitions statistic.
|
Modifier and Type | Method and Description |
---|---|
String |
StatisticBinningStrategy.binToString(ByteArray bin)
Get a human-readable string of a bin.
|
static byte[] |
StatisticValue.getValueId(StatisticId<?> statisticId,
ByteArray bin)
Get a unique identifier for a value given a statistic id and bin.
|
default <T> double |
BinningStrategy.getWeight(ByteArray bin,
DataTypeAdapter<T> type,
T entry,
GeoWaveRow... rows)
This computes a weight for the bin of a given entry.
|
static BinConstraints |
BinConstraints.of(ByteArray... exactMatchBins)
Sets the bins of the query explicitly.
|
static BinConstraints |
BinConstraints.ofPrefix(ByteArray... prefixBins)
Sets the bins of the query by prefix.
|
void |
StatisticValue.setBin(ByteArray bin)
Sets the bin for this value.
|
Modifier and Type | Method and Description |
---|---|
<V extends StatisticValue<R>,R> |
BaseDataStore.getBinnedStatisticValues(Statistic<V> stat,
BinConstraints binConstraints) |
Modifier and Type | Method and Description |
---|---|
protected void |
BaseDataStore.deleteFromDataIndex(Map<Short,Set<ByteArray>> dataIdsToDelete,
String... authorizations) |
Modifier and Type | Method and Description |
---|---|
protected ByteArray |
AbstractGeoWavePersistence.getCombinedId(ByteArray primaryId,
ByteArray secondaryId) |
protected ByteArray |
AdapterIndexMappingStoreImpl.getPrimaryId(AdapterToIndexMapping persistedObject) |
protected ByteArray |
PropertyStoreImpl.getPrimaryId(DataStoreProperty persistedObject) |
protected ByteArray |
IndexStoreImpl.getPrimaryId(Index persistedObject) |
protected ByteArray |
AdapterStoreImpl.getPrimaryId(InternalDataAdapter<?> persistedObject) |
protected ByteArray |
DataStatisticsStoreImpl.getPrimaryId(Statistic<? extends StatisticValue<?>> persistedObject) |
protected abstract ByteArray |
AbstractGeoWavePersistence.getPrimaryId(T persistedObject) |
protected ByteArray |
AdapterIndexMappingStoreImpl.getSecondaryId(AdapterToIndexMapping persistedObject) |
protected ByteArray |
DataStatisticsStoreImpl.getSecondaryId(Statistic<? extends StatisticValue<?>> persistedObject) |
protected ByteArray |
AbstractGeoWavePersistence.getSecondaryId(T persistedObject) |
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractGeoWavePersistence.addObject(ByteArray id,
ByteArray secondaryId,
T object) |
protected void |
AbstractGeoWavePersistence.addObjectToCache(ByteArray primaryId,
ByteArray secondaryId,
T object,
String... authorizations) |
protected boolean |
AbstractGeoWavePersistence.deleteObject(ByteArray primaryId,
ByteArray secondaryId,
String... authorizations) |
protected boolean |
AbstractGeoWavePersistence.deleteObjectFromCache(ByteArray primaryId,
ByteArray secondaryId) |
protected static <T extends Persistable> |
AbstractGeoWavePersistence.deleteObjects(ByteArray primaryId,
ByteArray secondaryId,
boolean primaryIdPrefix,
DataStoreOperations operations,
MetadataType type,
AbstractGeoWavePersistence<T> cacheDeleter,
String... authorizations) |
protected static <T extends Persistable> |
AbstractGeoWavePersistence.deleteObjects(ByteArray primaryId,
ByteArray secondaryId,
DataStoreOperations operations,
MetadataType type,
AbstractGeoWavePersistence<T> cacheDeleter,
String... authorizations) |
boolean |
AbstractGeoWavePersistence.deleteObjects(ByteArray primaryId,
ByteArray secondaryId,
String... authorizations) |
boolean |
AbstractGeoWavePersistence.deleteObjects(ByteArray secondaryId,
String... authorizations) |
protected CloseableIterator<T> |
AbstractGeoWavePersistence.getAllObjectsWithSecondaryId(ByteArray secondaryId,
String... authorizations) |
protected CloseableIterator<? extends Statistic<? extends StatisticValue<?>>> |
DataStatisticsStoreImpl.getBasicStatisticsInternal(ByteArray secondaryId,
StatisticType<? extends StatisticValue<?>> statisticType,
String tag) |
protected CloseableIterator<? extends Statistic<? extends StatisticValue<?>>> |
DataStatisticsStoreImpl.getCachedObject(ByteArray primaryId,
ByteArray secondaryId) |
protected ByteArray |
AbstractGeoWavePersistence.getCombinedId(ByteArray primaryId,
ByteArray secondaryId) |
protected CloseableIterator<? extends Statistic<? extends StatisticValue<?>>> |
DataStatisticsStoreImpl.getFieldStatisticsInternal(ByteArray secondaryId,
StatisticType<? extends StatisticValue<?>> statisticType,
String fieldName,
String tag) |
protected T |
AbstractGeoWavePersistence.getObject(ByteArray primaryId,
ByteArray secondaryId,
String... authorizations) |
protected Object |
AbstractGeoWavePersistence.getObjectFromCache(ByteArray primaryId,
ByteArray secondaryId,
String... authorizations) |
<V extends StatisticValue<R>,R> |
DataStatisticsStoreImpl.getStatisticValue(Statistic<V> statistic,
ByteArray bin,
String... authorizations) |
<V extends StatisticValue<R>,R> |
DataStatisticsStoreImpl.getStatisticValues(Statistic<V> statistic,
ByteArray binPrefix,
String... authorizations) |
<V extends StatisticValue<R>,R> |
DataStatisticsStoreImpl.incorporateStatisticValue(Statistic<V> statistic,
V value,
ByteArray bin) |
protected T |
AbstractGeoWavePersistence.internalGetObject(ByteArray primaryId,
ByteArray secondaryId,
boolean warnIfNotExists,
String... authorizations) |
protected boolean |
AbstractGeoWavePersistence.objectExists(ByteArray primaryId,
ByteArray secondaryId,
String... authorizations) |
void |
AbstractGeoWavePersistence.remove(ByteArray adapterId) |
boolean |
DataStatisticsStoreImpl.removeStatisticValue(Statistic<? extends StatisticValue<?>> statistic,
ByteArray bin) |
<V extends StatisticValue<R>,R> |
DataStatisticsStoreImpl.setStatisticValue(Statistic<V> statistic,
V value,
ByteArray bin) |
Modifier and Type | Method and Description |
---|---|
AggregationQuery<BinningAggregationOptions<P,T>,Map<ByteArray,R>,T> |
AggregationQueryBuilderImpl.buildWithBinningStrategy(BinningStrategy binningStrategy,
int maxBins) |
Map<ByteArray,R> |
BinningAggregation.getResult() |
Map<ByteArray,R> |
BinningAggregation.merge(Map<ByteArray,R> result1,
Map<ByteArray,R> result2) |
Map<ByteArray,R> |
BinningAggregation.resultFromBinary(byte[] binary) |
Modifier and Type | Method and Description |
---|---|
Map<ByteArray,R> |
BinningAggregation.merge(Map<ByteArray,R> result1,
Map<ByteArray,R> result2) |
Map<ByteArray,R> |
BinningAggregation.merge(Map<ByteArray,R> result1,
Map<ByteArray,R> result2) |
byte[] |
BinningAggregation.resultToBinary(Map<ByteArray,R> result) |
Modifier and Type | Field and Description |
---|---|
protected Map<ByteArray,List<MultiDimensionalNumericData>> |
BasicQueryFilter.binnedConstraints |
Modifier and Type | Method and Description |
---|---|
boolean |
DedupeFilter.applyDedupeFilter(short adapterId,
ByteArray dataId) |
Modifier and Type | Class and Description |
---|---|
class |
StatisticType<V extends StatisticValue<?>>
This class serves as the base implementation for a statistic type, based on
ByteArray . |
Modifier and Type | Field and Description |
---|---|
protected ByteArray |
StatisticId.cachedBytes |
protected ByteArray |
StatisticId.groupId |
Modifier and Type | Method and Description |
---|---|
static ByteArray |
StatisticId.generateUniqueId(StatisticType<?> statisticType,
String tag)
Generate a unique id with the given statistic type and tag.
|
static ByteArray |
StatisticValueReader.getBinFromValueId(StatisticId<?> statisticId,
byte[] valueId) |
ByteArray |
StatisticId.getGroupId()
Get the group id of the identifier.
|
ByteArray |
StatisticId.getUniqueId()
Get the unique id of the identifier.
|
Modifier and Type | Method and Description |
---|---|
static RowRangeHistogramStatistic.RowRangeHistogramValue |
InternalStatisticsHelper.getRangeStats(DataStatisticsStore statisticsStore,
String indexName,
String typeName,
ByteArray partitionKey,
String... authorizations)
Get the row range histogram of a specific partition in an index.
|
static RowRangeHistogramStatistic.RowRangeHistogramValue |
InternalStatisticsHelper.getRangeStats(Index index,
List<Short> adapterIds,
PersistentAdapterStore adapterStore,
DataStatisticsStore statisticsStore,
ByteArray partitionKey,
String... authorizations)
Get the row range histogram of an index partition.
|
<V extends StatisticValue<R>,R> |
DataStatisticsStore.getStatisticValue(Statistic<V> statistic,
ByteArray bin,
String... authorizations)
Return the value of the given statistic.
|
<V extends StatisticValue<R>,R> |
DataStatisticsStore.getStatisticValues(Statistic<V> statistic,
ByteArray binPrefix,
String... authorizations)
Return the values of the given statistic that have bins that start with the given prefix.
|
protected void |
StatisticUpdateHandler.handleBin(org.locationtech.geowave.core.store.statistics.StatisticUpdateHandler.Handler<T,V,R> handler,
Map<ByteArray,V> binnedValues,
ByteArray bin,
T entry,
GeoWaveRow... rows) |
<V extends StatisticValue<R>,R> |
DataStatisticsStore.incorporateStatisticValue(Statistic<V> statistic,
V value,
ByteArray bin)
Add the statistic value to the store, preserving the existing value.
|
boolean |
DataStatisticsStore.removeStatisticValue(Statistic<? extends StatisticValue<?>> statistic,
ByteArray bin)
Removes the value of the given statistic.
|
<V extends StatisticValue<R>,R> |
DataStatisticsStore.setStatisticValue(Statistic<V> statistic,
V value,
ByteArray bin)
This will write the statistic value to the underlying store.
|
Modifier and Type | Method and Description |
---|---|
protected void |
StatisticUpdateHandler.handleBin(org.locationtech.geowave.core.store.statistics.StatisticUpdateHandler.Handler<T,V,R> handler,
Map<ByteArray,V> binnedValues,
ByteArray bin,
T entry,
GeoWaveRow... rows) |
protected void |
StatisticUpdateHandler.handleBinnedRows(org.locationtech.geowave.core.store.statistics.StatisticUpdateHandler.Handler<T,V,R> handler,
Map<ByteArray,V> binnedValues,
T entry,
GeoWaveRow... rows) |
Constructor and Description |
---|
StatisticId(ByteArray groupId,
StatisticType<V> statisticType,
String tag)
Create a new statistic id with the given group, statistic type, and tag.
|
Modifier and Type | Class and Description |
---|---|
class |
DataTypeStatisticType<V extends StatisticValue<?>>
Statistic type for data type statistics.
|
Modifier and Type | Method and Description |
---|---|
protected static ByteArray[] |
FieldValueBinningStrategy.getAllCombinations(ByteArray[][] perFieldBins) |
static ByteArray[] |
BinningStrategyUtils.getAllCombinations(ByteArray[][] individualBins,
java.util.function.Function<ByteArray[],ByteArray> concatenateByteArrays)
in the case of queries of composite or multi-field bins, we need to query all combinations of
individual bins
|
static ByteArray |
PartitionBinningStrategy.getBin(byte[] partitionKey) |
static ByteArray |
CompositeBinningStrategy.getBin(ByteArray... bins) |
protected static ByteArray |
FieldValueBinningStrategy.getBin(ByteArray[] fieldValues) |
static ByteArray |
DataTypeBinningStrategy.getBin(DataTypeAdapter<?> adapter) |
static ByteArray |
DataTypeBinningStrategy.getBin(String typeName) |
<T> ByteArray[] |
DataTypeBinningStrategy.getBins(DataTypeAdapter<T> adapter,
T entry,
GeoWaveRow... rows) |
<T> ByteArray[] |
PartitionBinningStrategy.getBins(DataTypeAdapter<T> adapter,
T entry,
GeoWaveRow... rows) |
<T> ByteArray[] |
FieldValueBinningStrategy.getBins(DataTypeAdapter<T> adapter,
T entry,
GeoWaveRow... rows) |
<T> ByteArray[] |
CompositeBinningStrategy.getBins(DataTypeAdapter<T> adapter,
T entry,
GeoWaveRow... rows) |
protected ByteArray |
NumericRangeFieldValueBinningStrategy.getSingleBin(Object value) |
protected ByteArray |
FieldValueBinningStrategy.getSingleBin(Object value) |
Modifier and Type | Method and Description |
---|---|
boolean |
CompositeBinningStrategy.binMatches(Class<? extends StatisticBinningStrategy> binningStrategyClass,
ByteArray bin,
ByteArray subBin) |
String |
DataTypeBinningStrategy.binToString(ByteArray bin) |
String |
NumericRangeFieldValueBinningStrategy.binToString(ByteArray bin) |
String |
PartitionBinningStrategy.binToString(ByteArray bin) |
String |
FieldValueBinningStrategy.binToString(ByteArray bin) |
String |
CompositeBinningStrategy.binToString(ByteArray bin) |
protected static ByteArray[] |
FieldValueBinningStrategy.getAllCombinations(ByteArray[][] perFieldBins) |
static ByteArray[] |
BinningStrategyUtils.getAllCombinations(ByteArray[][] individualBins,
java.util.function.Function<ByteArray[],ByteArray> concatenateByteArrays)
in the case of queries of composite or multi-field bins, we need to query all combinations of
individual bins
|
static ByteArray |
CompositeBinningStrategy.getBin(ByteArray... bins) |
protected static ByteArray |
FieldValueBinningStrategy.getBin(ByteArray[] fieldValues) |
org.apache.commons.lang3.Range<Double> |
NumericRangeFieldValueBinningStrategy.getRange(ByteArray bytes) |
Map<String,org.apache.commons.lang3.Range<Double>> |
NumericRangeFieldValueBinningStrategy.getRanges(ByteArray bytes) |
org.apache.commons.lang3.tuple.Pair<StatisticBinningStrategy,ByteArray>[] |
CompositeBinningStrategy.getSubBins(ByteArray bin) |
Modifier and Type | Method and Description |
---|---|
static ByteArray[] |
BinningStrategyUtils.getAllCombinations(ByteArray[][] individualBins,
java.util.function.Function<ByteArray[],ByteArray> concatenateByteArrays)
in the case of queries of composite or multi-field bins, we need to query all combinations of
individual bins
|
Modifier and Type | Class and Description |
---|---|
class |
FieldStatisticType<V extends StatisticValue<?>>
Statistic type for field statistics.
|
Modifier and Type | Method and Description |
---|---|
static ByteArray |
FieldStatisticId.generateUniqueId(StatisticType<?> statisticType,
String fieldName,
String tag)
Generate a unique id with the given statistic type, field name, and tag.
|
ByteArray |
FieldStatisticId.getUniqueId()
Get the unique id of the identifier.
|
Constructor and Description |
---|
FieldStatisticId(ByteArray groupId,
StatisticType<V> statisticType,
String fieldName,
String tag)
Create a new statistic id with the given group, statistic type, field name and tag.
|
Modifier and Type | Class and Description |
---|---|
class |
IndexStatisticType<V extends StatisticValue<?>>
Statistic type for index statistics.
|
Modifier and Type | Method and Description |
---|---|
protected static ByteArray |
PartitionsStatistic.getPartitionKey(byte[] partitionBytes) |
Modifier and Type | Method and Description |
---|---|
Map<ByteArray,Long> |
FieldVisibilityCountStatistic.FieldVisibilityCountValue.getValue() |
Set<ByteArray> |
PartitionsStatistic.PartitionsValue.getValue() |
Modifier and Type | Method and Description |
---|---|
ByteArray[] |
BinConstraintsImpl.ExplicitConstraints.getBins() |
Constructor and Description |
---|
BinConstraintsImpl(ByteArray[] bins,
boolean isPrefix) |
ExplicitConstraints(ByteArray[] bins) |
ExplicitConstraints(ByteArray[] bins,
boolean isPrefix) |
ExplicitConstraints(ByteArray[] bins,
boolean isPrefix,
boolean isAllBins) |
ExplicitConstraints(ByteArray[] bins,
ByteArrayRange[] binRanges,
boolean isPrefix,
boolean isAllBins) |
Modifier and Type | Method and Description |
---|---|
static ByteArray |
DataStoreUtils.ensureUniqueId(byte[] id,
boolean hasMetadata) |
Modifier and Type | Method and Description |
---|---|
static String |
SingleEntryFilterIterator.encodeIDs(List<ByteArray> dataIds) |
Modifier and Type | Method and Description |
---|---|
protected TreeSet<IntermediateSplitInfo> |
AccumuloSplitsProvider.populateIntermediateSplits(TreeSet<IntermediateSplitInfo> splits,
DataStoreOperations operations,
Index index,
List<Short> adapterIds,
Map<org.apache.commons.lang3.tuple.Pair<Index,ByteArray>,RowRangeHistogramStatistic.RowRangeHistogramValue> statsCache,
TransientAdapterStore adapterStore,
InternalAdapterStore internalAdapterStore,
DataStatisticsStore statsStore,
Integer maxSplits,
QueryConstraints constraints,
double[] targetResolutionPerDimensionForHierarchicalIndex,
IndexMetaData[] indexMetadata,
String[] authorizations) |
Modifier and Type | Method and Description |
---|---|
boolean |
AccumuloOperations.delete(String tableName,
ByteArray rowId,
String columnFamily,
byte[] columnQualifier,
String... additionalAuthorizations) |
void |
AccumuloOperations.ensurePartition(ByteArray partition,
String tableName) |
Modifier and Type | Method and Description |
---|---|
boolean |
AccumuloOperations.delete(String tableName,
List<ByteArray> rowIds,
String columnFamily,
byte[] columnQualifier,
String... authorizations) |
Modifier and Type | Field and Description |
---|---|
protected Map<ByteArray,com.datastax.oss.driver.api.core.cql.BatchStatementBuilder> |
BatchHandler.batches |
Modifier and Type | Method and Description |
---|---|
ByteBuffer |
CassandraOperations.ByteArrayIdToByteBuffer.apply(ByteArray input) |
Modifier and Type | Method and Description |
---|---|
static Set<ByteArray> |
FileSystemUtils.getPartitions(Path directory,
FileSystemDataFormatter.IndexFormatter indexFormatter,
String indexName,
String typeName) |
Modifier and Type | Method and Description |
---|---|
protected TreeSet<IntermediateSplitInfo> |
HBaseSplitsProvider.populateIntermediateSplits(TreeSet<IntermediateSplitInfo> splits,
DataStoreOperations operations,
Index index,
List<Short> adapterIds,
Map<org.apache.commons.lang3.tuple.Pair<Index,ByteArray>,RowRangeHistogramStatistic.RowRangeHistogramValue> statsCache,
TransientAdapterStore adapterStore,
InternalAdapterStore internalAdapterStore,
DataStatisticsStore statsStore,
Integer maxSplits,
QueryConstraints query,
double[] targetResolutionPerDimensionForHierarchicalIndex,
IndexMetaData[] indexMetadata,
String[] authorizations) |
Modifier and Type | Field and Description |
---|---|
protected Set<ByteArray> |
HBaseWriter.duplicateRowTracker |
protected Set<ByteArray> |
HBaseRowDeleter.duplicateRowTracker |
protected Set<ByteArray> |
HBaseMetadataWriter.duplicateRowTracker |
Modifier and Type | Method and Description |
---|---|
List<ByteArray> |
HBaseOperations.getTableRegions(String tableNameStr) |
Modifier and Type | Method and Description |
---|---|
static Set<ByteArray> |
RedisUtils.getPartitions(org.redisson.api.RedissonClient client,
String setNamePrefix) |
Modifier and Type | Field and Description |
---|---|
static ByteArray |
RocksDBUtils.EMPTY_PARTITION_KEY |
Modifier and Type | Method and Description |
---|---|
static Set<ByteArray> |
RocksDBUtils.getPartitions(String directory,
String tableNamePrefix) |
Modifier and Type | Method and Description |
---|---|
ByteArray |
GeoWaveInputKey.getDataId() |
Modifier and Type | Method and Description |
---|---|
void |
GeoWaveInputKey.setDataId(ByteArray dataId) |
Constructor and Description |
---|
GeoWaveInputKey(short internalAdapterId,
ByteArray dataId) |
Modifier and Type | Method and Description |
---|---|
protected RowRangeHistogramStatistic.RowRangeHistogramValue |
SplitsProvider.getHistStats(Index index,
List<Short> adapterIds,
PersistentAdapterStore adapterStore,
DataStatisticsStore statsStore,
Map<org.apache.commons.lang3.tuple.Pair<Index,ByteArray>,RowRangeHistogramStatistic.RowRangeHistogramValue> statsCache,
ByteArray partitionKey,
String[] authorizations) |
Modifier and Type | Method and Description |
---|---|
protected RowRangeHistogramStatistic.RowRangeHistogramValue |
SplitsProvider.getHistStats(Index index,
List<Short> adapterIds,
PersistentAdapterStore adapterStore,
DataStatisticsStore statsStore,
Map<org.apache.commons.lang3.tuple.Pair<Index,ByteArray>,RowRangeHistogramStatistic.RowRangeHistogramValue> statsCache,
ByteArray partitionKey,
String[] authorizations) |
protected TreeSet<IntermediateSplitInfo> |
SplitsProvider.populateIntermediateSplits(TreeSet<IntermediateSplitInfo> splits,
DataStoreOperations operations,
Index index,
List<Short> adapterIds,
Map<org.apache.commons.lang3.tuple.Pair<Index,ByteArray>,RowRangeHistogramStatistic.RowRangeHistogramValue> statsCache,
TransientAdapterStore adapterStore,
InternalAdapterStore internalAdapterStore,
DataStatisticsStore statsStore,
Integer maxSplits,
QueryConstraints constraints,
double[] targetResolutionPerDimensionForHierarchicalIndex,
IndexMetaData[] indexMetadata,
String[] authorizations) |
Modifier and Type | Method and Description |
---|---|
protected ByteArray |
LegacyAdapterIndexMappingStore.getPrimaryId(LegacyAdapterToIndexMapping persistedObject) |
Copyright © 2013–2022. All rights reserved.