org.locationtech.geowave.core.store.util

Class DataStoreUtils

java.lang.Object

org.locationtech.geowave.core.store.util.DataStoreUtils

public class DataStoreUtils
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAULT_GEOWAVE_DIRECTORY
static byte[]	EMTPY_VISIBILITY
static CommonQueryOptions.HintKey<Integer>	MAX_RANGE_DECOMPOSITION
static CommonQueryOptions.HintKey<double[]>	MAX_RESOLUTION_SUBSAMPLING_PER_DIMENSION
static CommonQueryOptions.HintKey<double[]>	TARGET_RESOLUTION_PER_DIMENSION_FOR_HIERARCHICAL_INDEX
static VisibilityHandler	UNCONSTRAINED_VISIBILITY
static int	UNIQUE_ADDED_BYTES
static byte	UNIQUE_ID_DELIMITER

Constructor Summary

Constructors

Constructor and Description
DataStoreUtils()

Method Summary

Modifier and Type	Method and Description
static FlattenedUnreadData	aggregateFieldData(GeoWaveKey key, GeoWaveValue value, PersistentDataset<Object> commonData, CommonIndexModel model, List<String> commonIndexFieldIds)
static <T> long	cardinality(DataStatisticsStore statisticsStore, RowRangeHistogramStatistic rowRangeHistogramStatistic, DataTypeAdapter<?> adapter, Index index, QueryRanges queryRanges)
static QueryRanges	constraintsToQueryRanges(List<MultiDimensionalNumericData> constraints, Index index, double[] targetResolutionPerDimensionForHierarchicalIndex, int maxRanges, IndexMetaData... hints)
static <T> FlattenedDataSet	decomposeFlattenedFields(byte[] bitmask, byte[] flattenedValue, byte[] commonVisibility, int maxFieldPosition) Takes a byte array representing a serialized composite group of FieldInfos sharing a common visibility and returns a List of the individual FieldInfos
static ByteArray	ensureUniqueId(byte[] id, boolean hasMetadata)
static DataTypeAdapter	getDataAdapter(DataStorePluginOptions dataStore, String typeName)
static <T> InsertionIds	getInsertionIdsForEntry(T entry, InternalDataAdapter adapter, AdapterToIndexMapping indexMapping, Index index)
static String	getQualifiedTableName(String tableNamespace, String unqualifiedTableName)
static List<String>	getUniqueDimensionFields(CommonIndexModel model)
static boolean	isMergingIteratorRequired(RangeReaderParams<?> readerParams, boolean visibilityEnabled)
static InsertionIds	keysToInsertionIds(GeoWaveKey... geoWaveKeys)
static List<Index>	loadIndices(DataStore dataStore, String indexNames)
static List<Index>	loadIndices(IndexStore indexStore, String indexNames)
static boolean	mergeData(DataStoreOperations operations, Integer maxRangeDecomposition, Index index, PersistentAdapterStore adapterStore, InternalAdapterStore internalAdapterStore, AdapterIndexMappingStore adapterIndexMappingStore)
static GeoWaveRow	mergeSingleRowValues(GeoWaveRow singleRow, RowMergingDataAdapter.RowTransform rowTransform)
static byte[]	mergeVisibilities(byte[] vis1, byte[] vis2)
static byte[]	removeUniqueId(byte[] dataId)
static boolean	rowIdsMatch(GeoWaveKey rowId1, GeoWaveKey rowId2)
static void	safeMetadataDelete(MetadataDeleter deleter, DataStoreOperations operations, MetadataType metadataType, MetadataQuery query)
static boolean	startsWithIfPrefix(byte[] source, byte[] match, boolean prefix)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_GEOWAVE_DIRECTORY

public static String DEFAULT_GEOWAVE_DIRECTORY

MAX_RESOLUTION_SUBSAMPLING_PER_DIMENSION

public static CommonQueryOptions.HintKey<double[]> MAX_RESOLUTION_SUBSAMPLING_PER_DIMENSION

MAX_RANGE_DECOMPOSITION

public static CommonQueryOptions.HintKey<Integer> MAX_RANGE_DECOMPOSITION

TARGET_RESOLUTION_PER_DIMENSION_FOR_HIERARCHICAL_INDEX

public static CommonQueryOptions.HintKey<double[]> TARGET_RESOLUTION_PER_DIMENSION_FOR_HIERARCHICAL_INDEX

UNIQUE_ADDED_BYTES

public static final int UNIQUE_ADDED_BYTES

See Also:

Constant Field Values

UNIQUE_ID_DELIMITER

public static final byte UNIQUE_ID_DELIMITER

See Also:

Constant Field Values

UNCONSTRAINED_VISIBILITY

public static final VisibilityHandler UNCONSTRAINED_VISIBILITY

EMTPY_VISIBILITY

public static final byte[] EMTPY_VISIBILITY

Constructor Detail

DataStoreUtils

public DataStoreUtils()

Method Detail

getDataAdapter

public static DataTypeAdapter getDataAdapter(DataStorePluginOptions dataStore,
                                             String typeName)

aggregateFieldData

public static FlattenedUnreadData aggregateFieldData(GeoWaveKey key,
                                                     GeoWaveValue value,
                                                     PersistentDataset<Object> commonData,
                                                     CommonIndexModel model,
                                                     List<String> commonIndexFieldIds)

startsWithIfPrefix

public static boolean startsWithIfPrefix(byte[] source,
                                         byte[] match,
                                         boolean prefix)

getUniqueDimensionFields

public static List<String> getUniqueDimensionFields(CommonIndexModel model)

cardinality

public static <T> long cardinality(DataStatisticsStore statisticsStore,
                                   RowRangeHistogramStatistic rowRangeHistogramStatistic,
                                   DataTypeAdapter<?> adapter,
                                   Index index,
                                   QueryRanges queryRanges)

getInsertionIdsForEntry

public static <T> InsertionIds getInsertionIdsForEntry(T entry,
                                                       InternalDataAdapter adapter,
                                                       AdapterToIndexMapping indexMapping,
                                                       Index index)

keysToInsertionIds

public static InsertionIds keysToInsertionIds(GeoWaveKey... geoWaveKeys)

rowIdsMatch

public static boolean rowIdsMatch(GeoWaveKey rowId1,
                                  GeoWaveKey rowId2)

removeUniqueId

public static byte[] removeUniqueId(byte[] dataId)

decomposeFlattenedFields

public static <T> FlattenedDataSet decomposeFlattenedFields(byte[] bitmask,
                                                            byte[] flattenedValue,
                                                            byte[] commonVisibility,
                                                            int maxFieldPosition)

Takes a byte array representing a serialized composite group of FieldInfos sharing a common visibility and returns a List of the individual FieldInfos

Parameters:

bitmask - the composite bitmask representing the fields contained within the flattenedValue

flattenedValue - the serialized composite FieldInfo

commonVisibility - the shared visibility

maxFieldPosition - can short-circuit read and defer decomposition of fields after a given position

Returns:

the dataset that has been read

constraintsToQueryRanges

public static QueryRanges constraintsToQueryRanges(List<MultiDimensionalNumericData> constraints,
                                                   Index index,
                                                   double[] targetResolutionPerDimensionForHierarchicalIndex,
                                                   int maxRanges,
                                                   IndexMetaData... hints)

getQualifiedTableName

public static String getQualifiedTableName(String tableNamespace,
                                           String unqualifiedTableName)

ensureUniqueId

public static ByteArray ensureUniqueId(byte[] id,
                                       boolean hasMetadata)

mergeVisibilities

public static byte[] mergeVisibilities(byte[] vis1,
                                       byte[] vis2)

mergeSingleRowValues

public static GeoWaveRow mergeSingleRowValues(GeoWaveRow singleRow,
                                              RowMergingDataAdapter.RowTransform rowTransform)

mergeData

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

isMergingIteratorRequired

public static boolean isMergingIteratorRequired(RangeReaderParams<?> readerParams,
                                                boolean visibilityEnabled)

loadIndices

public static List<Index> loadIndices(IndexStore indexStore,
                                      String indexNames)

loadIndices

public static List<Index> loadIndices(DataStore dataStore,
                                      String indexNames)

safeMetadataDelete

public static void safeMetadataDelete(MetadataDeleter deleter,
                                      DataStoreOperations operations,
                                      MetadataType metadataType,
                                      MetadataQuery query)