org.locationtech.geowave.datastore.hbase.mapreduce

Class HBaseSplitsProvider

java.lang.Object

org.locationtech.geowave.mapreduce.splits.SplitsProvider

org.locationtech.geowave.datastore.hbase.mapreduce.HBaseSplitsProvider

public class HBaseSplitsProvider
extends SplitsProvider

Constructor Summary

Constructors

Constructor and Description
HBaseSplitsProvider()

Method Summary

Modifier and Type	Method and Description
protected static void	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>	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 TreeSet<IntermediateSplitInfo>	populateIntermediateSplits(TreeSet<IntermediateSplitInfo> splits, DataStoreOperations operations, Index index, List<Short> adapterIds, Map<org.apache.commons.lang3.tuple.Pair<Index,ByteArray>,RowRangeHistogramStatistics<?>> statsCache, TransientAdapterStore adapterStore, DataStatisticsStore statsStore, Integer maxSplits, QueryConstraints query, double[] targetResolutionPerDimensionForHierarchicalIndex, IndexMetaData[] indexMetadata, String[] authorizations)
protected static GeoWaveRowRange	rangeIntersection(GeoWaveRowRange thisRange, GeoWaveRowRange otherRange)

Methods inherited from class org.locationtech.geowave.mapreduce.splits.SplitsProvider

extractBytes, extractBytes, fromRowRange, getCardinality, getEnd, getHistStats, getInclusiveEndKey, getKeyFromBigInteger, getMidpoint, getPartitionStats, getRange, getRangeLength, getSplits, getStart, toRowRange

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseSplitsProvider

public HBaseSplitsProvider()

Method Detail

populateIntermediateSplits

protected TreeSet<IntermediateSplitInfo> populateIntermediateSplits(TreeSet<IntermediateSplitInfo> splits,
                                                                    DataStoreOperations operations,
                                                                    Index index,
                                                                    List<Short> adapterIds,
                                                                    Map<org.apache.commons.lang3.tuple.Pair<Index,ByteArray>,RowRangeHistogramStatistics<?>> statsCache,
                                                                    TransientAdapterStore adapterStore,
                                                                    DataStatisticsStore statsStore,
                                                                    Integer maxSplits,
                                                                    QueryConstraints query,
                                                                    double[] targetResolutionPerDimensionForHierarchicalIndex,
                                                                    IndexMetaData[] indexMetadata,
                                                                    String[] authorizations)
                                                             throws IOException

Overrides:

populateIntermediateSplits in class SplitsProvider

Throws:

IOException

binFullRange

protected static void binFullRange(Map<org.apache.hadoop.hbase.HRegionLocation,Map<org.apache.hadoop.hbase.HRegionInfo,List<ByteArrayRange>>> binnedRanges,
                                   org.apache.hadoop.hbase.client.RegionLocator regionLocator)
                            throws IOException

Throws:

IOException

binRanges

protected static List<ByteArrayRange> 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)
                                         throws IOException

Throws:

IOException

rangeIntersection

protected static GeoWaveRowRange rangeIntersection(GeoWaveRowRange thisRange,
                                                   GeoWaveRowRange otherRange)