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