Modifier and Type | Method and Description |
---|---|
ByteArrayRange |
SinglePartitionQueryRanges.getSingleRange() |
static ByteArrayRange |
ByteArrayUtils.getSingleRange(List<ByteArrayRange> ranges) |
ByteArrayRange |
ByteArrayRange.intersection(ByteArrayRange other) |
ByteArrayRange |
ByteArrayRange.union(ByteArrayRange other) |
Modifier and Type | Method and Description |
---|---|
List<ByteArrayRange> |
QueryRanges.getCompositeQueryRanges() |
Collection<ByteArrayRange> |
SinglePartitionQueryRanges.getSortKeyRanges() |
static Collection<ByteArrayRange> |
ByteArrayRange.mergeIntersections(Collection<ByteArrayRange> ranges,
ByteArrayRange.MergeOperation op) |
Modifier and Type | Method and Description |
---|---|
static void |
ByteArrayUtils.addAllIntermediaryByteArrays(List<byte[]> retVal,
ByteArrayRange range) |
int |
ByteArrayRange.compareTo(ByteArrayRange other) |
ByteArrayRange |
ByteArrayRange.intersection(ByteArrayRange other) |
boolean |
ByteArrayRange.intersects(ByteArrayRange other) |
ByteArrayRange |
ByteArrayRange.union(ByteArrayRange other) |
Modifier and Type | Method and Description |
---|---|
static ByteArrayRange |
ByteArrayUtils.getSingleRange(List<ByteArrayRange> ranges) |
static boolean |
ByteArrayUtils.matchesPrefixRanges(byte[] bytes,
List<ByteArrayRange> ranges) |
static Collection<ByteArrayRange> |
ByteArrayRange.mergeIntersections(Collection<ByteArrayRange> ranges,
ByteArrayRange.MergeOperation op) |
Constructor and Description |
---|
QueryRanges(ByteArrayRange singleSortKeyRange) |
SinglePartitionQueryRanges(ByteArrayRange singleSortKeyRange) |
Constructor and Description |
---|
SinglePartitionQueryRanges(byte[] partitionKey,
Collection<ByteArrayRange> sortKeyRanges) |
SinglePartitionQueryRanges(List<ByteArrayRange> sortKeyRanges) |
Modifier and Type | Method and Description |
---|---|
ByteArrayRange[] |
RangeDecomposition.getRanges() |
Constructor and Description |
---|
RangeDecomposition(ByteArrayRange[] ranges)
Constructor used to create a new Range Decomposition object.
|
Modifier and Type | Method and Description |
---|---|
ByteArrayRange[] |
BinConstraints.ByteArrayConstraints.getBinRanges()
get the bin ranges to query for
|
Modifier and Type | Method and Description |
---|---|
static BinConstraints |
BinConstraints.ofRange(ByteArrayRange... binRanges)
Sets the bins of the query by range.
|
Modifier and Type | Method and Description |
---|---|
<V extends StatisticValue<R>,R> |
DataStatisticsStoreImpl.getStatisticValues(Statistic<V> statistic,
ByteArrayRange[] binRanges,
String... authorizations) |
Modifier and Type | Method and Description |
---|---|
ByteArrayRange[] |
MetadataQuery.getPrimaryIdRanges() |
Constructor and Description |
---|
MetadataQuery(ByteArrayRange[] primaryIdRanges,
byte[] secondaryId,
String... authorizations) |
Modifier and Type | Method and Description |
---|---|
<V extends StatisticValue<R>,R> |
DataStatisticsStore.getStatisticValues(Statistic<V> statistic,
ByteArrayRange[] binRanges,
String... authorizations)
Return the values of the given statistic that have bins that match the given ranges.
|
Modifier and Type | Method and Description |
---|---|
ByteArrayRange[] |
BinConstraintsImpl.ExplicitConstraints.getBinRanges() |
Constructor and Description |
---|
BinConstraintsImpl(ByteArrayRange[] binRanges) |
ExplicitConstraints(ByteArray[] bins,
ByteArrayRange[] binRanges,
boolean isPrefix,
boolean isAllBins) |
ExplicitConstraints(ByteArrayRange[] binRanges) |
Constructor and Description |
---|
AccumuloDeleter(org.apache.accumulo.core.client.BatchDeleter scanner,
List<ByteArrayRange> clientFilterRanges,
GeoWaveRowIteratorTransformer<T> transformer,
int partitionKeyLength,
boolean wholeRowEncoding,
boolean clientSideRowMerging,
boolean parallel) |
AccumuloReader(org.apache.accumulo.core.client.ScannerBase scanner,
List<ByteArrayRange> clientFilterRanges,
GeoWaveRowIteratorTransformer<T> transformer,
int partitionKeyLength,
boolean wholeRowEncoding,
boolean clientSideRowMerging,
boolean parallel) |
Modifier and Type | Method and Description |
---|---|
static org.apache.accumulo.core.data.Range |
AccumuloUtils.byteArrayRangeToAccumuloRange(ByteArrayRange byteArrayRange) |
Modifier and Type | Method and Description |
---|---|
static TreeSet<org.apache.accumulo.core.data.Range> |
AccumuloUtils.byteArrayRangesToAccumuloRanges(List<ByteArrayRange> byteArrayRanges) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<GeoWaveMetadata> |
FileSystemMetadataTable.iterator(ByteArrayRange range) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<GeoWaveRow> |
FileSystemIndexTable.iterator(Collection<ByteArrayRange> ranges) |
Constructor and Description |
---|
AbstractFileSystemIterator(Path subDirectory,
Collection<ByteArrayRange> ranges,
java.util.function.Function<String,org.locationtech.geowave.datastore.filesystem.util.FileSystemKey> fileNameToKey) |
FileSystemRowIterator(Path subDirectory,
Collection<ByteArrayRange> ranges,
short adapterId,
String typeName,
String indexName,
byte[] partition,
FileSystemDataFormatter.IndexFormatter formatter,
java.util.function.Function<String,org.locationtech.geowave.datastore.filesystem.util.FileSystemKey> fileNameToKey) |
Modifier and Type | Method and Description |
---|---|
protected static List<ByteArrayRange> |
HBaseSplitsProvider.binRanges(List<ByteArrayRange> inputRanges,
Map<org.apache.hadoop.hbase.HRegionLocation,Map<org.apache.hadoop.hbase.HRegionInfo,List<ByteArrayRange>>> binnedRanges,
org.apache.hadoop.hbase.client.RegionLocator regionLocator) |
Modifier and Type | Method and Description |
---|---|
protected static void |
HBaseSplitsProvider.binFullRange(Map<org.apache.hadoop.hbase.HRegionLocation,Map<org.apache.hadoop.hbase.HRegionInfo,List<ByteArrayRange>>> binnedRanges,
org.apache.hadoop.hbase.client.RegionLocator regionLocator) |
protected static List<ByteArrayRange> |
HBaseSplitsProvider.binRanges(List<ByteArrayRange> inputRanges,
Map<org.apache.hadoop.hbase.HRegionLocation,Map<org.apache.hadoop.hbase.HRegionInfo,List<ByteArrayRange>>> binnedRanges,
org.apache.hadoop.hbase.client.RegionLocator regionLocator) |
protected static List<ByteArrayRange> |
HBaseSplitsProvider.binRanges(List<ByteArrayRange> inputRanges,
Map<org.apache.hadoop.hbase.HRegionLocation,Map<org.apache.hadoop.hbase.HRegionInfo,List<ByteArrayRange>>> binnedRanges,
org.apache.hadoop.hbase.client.RegionLocator regionLocator) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.filter.MultiRowRangeFilter |
HBaseOperations.getMultiRowRangeFilter(List<ByteArrayRange> ranges) |
Constructor and Description |
---|
HBaseParallelDecoder(GeoWaveRowIteratorTransformer<T> rowTransformer,
java.util.function.Supplier<org.apache.hadoop.hbase.client.Scan> scanProvider,
HBaseOperations operations,
List<ByteArrayRange> ranges,
int partitionKeyLength) |
Modifier and Type | Method and Description |
---|---|
static java.util.stream.Stream<org.apache.commons.lang3.Range<Double>> |
RedisUtils.getScoreRangesFromByteArrays(ByteArrayRange range) |
Modifier and Type | Method and Description |
---|---|
CloseableIterator<GeoWaveRow> |
RocksDBIndexTable.iterator(ByteArrayRange range) |
CloseableIterator<GeoWaveMetadata> |
RocksDBMetadataTable.iterator(ByteArrayRange range) |
Modifier and Type | Method and Description |
---|---|
static ByteArrayRange |
SplitsProvider.fromRowRange(GeoWaveRowRange range) |
Modifier and Type | Method and Description |
---|---|
static GeoWaveRowRange |
SplitsProvider.toRowRange(ByteArrayRange range,
int partitionKeyLength) |
Copyright © 2013–2022. All rights reserved.