Uses of Interface
org.apache.hadoop.hbase.regionserver.KeyValueScanner
Packages that use org.apache.hadoop.hbase.regionserver.KeyValueScanner
-
Uses of org.apache.hadoop.hbase.regionserver.KeyValueScanner in org.apache.hadoop.hbase.regionserver
Classes in org.apache.hadoop.hbase.regionserver that implement org.apache.hadoop.hbase.regionserver.KeyValueScanner in inModifier and TypeClassDescriptionclassorg.apache.hadoop.hbase.regionserver.KeyValueHeapImplements a heap merge across any number of KeyValueScanners.classorg.apache.hadoop.hbase.regionserver.MobStoreScannerScanner scans both the memstore and the MOB Store.classorg.apache.hadoop.hbase.regionserver.NonLazyKeyValueScannerA "non-lazy" scanner which always does a real seek operation.classorg.apache.hadoop.hbase.regionserver.NonReversedNonLazyKeyValueScannerA "non-reversed & non-lazy" scanner which does not support backward scanning and always does a real seek operation.classorg.apache.hadoop.hbase.regionserver.ReversedKeyValueHeapReversedKeyValueHeap is used for supporting reversed scanning.classorg.apache.hadoop.hbase.regionserver.ReversedMobStoreScannerReversedMobStoreScanner extends from ReversedStoreScanner, and is used to support reversed scanning in both the memstore and the MOB store.classorg.apache.hadoop.hbase.regionserver.ReversedStoreScannerReversedStoreScanner extends from StoreScanner, and is used to support reversed scanning.classorg.apache.hadoop.hbase.regionserver.SegmentScannerA scanner of a single memstore segment.classorg.apache.hadoop.hbase.regionserver.SnapshotSegmentScannerA basic SegmentScanner used against an ImmutableScanner snapshot Used flushing where we do a single pass, no reverse scanning or inserts happening.classorg.apache.hadoop.hbase.regionserver.StoreFileScannerKeyValueScanner adaptor over the Reader.classorg.apache.hadoop.hbase.regionserver.StoreScannerScanner scans both the memstore and the Store.Fields in org.apache.hadoop.hbase.regionserver declared as org.apache.hadoop.hbase.regionserver.KeyValueScanner in inModifier and TypeFieldDescriptionprotected org.apache.hadoop.hbase.regionserver.KeyValueScannerKeyValueHeap.currentThe current sub-scanner, i.e.Fields in org.apache.hadoop.hbase.regionserver with type parameters of type org.apache.hadoop.hbase.regionserver.KeyValueScanner in inModifier and TypeFieldDescriptionprotected PriorityQueue<org.apache.hadoop.hbase.regionserver.KeyValueScanner>KeyValueHeap.heapprotected List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>KeyValueHeap.scannersForDelayedCloseMethods in org.apache.hadoop.hbase.regionserver that return org.apache.hadoop.hbase.regionserver.KeyValueScanner in inModifier and TypeMethodDescriptionprotected org.apache.hadoop.hbase.regionserver.KeyValueScannerHMobStore.createScanner(org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, NavigableSet<byte[]> targetCols, long readPt) Gets the MobStoreScanner or MobReversedStoreScanner.protected org.apache.hadoop.hbase.regionserver.KeyValueScannerHStore.createScanner(org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, NavigableSet<byte[]> targetCols, long readPt) org.apache.hadoop.hbase.regionserver.KeyValueScannerCompositeImmutableSegment.getScanner(long readPoint) Creates the scanner for the given read pointorg.apache.hadoop.hbase.regionserver.KeyValueScannerHStore.getScanner(org.apache.hadoop.hbase.client.Scan scan, NavigableSet<byte[]> targetCols, long readPt) Return a scanner for both the memstore and the HStore files.protected org.apache.hadoop.hbase.regionserver.KeyValueScannerSegment.getScanner(long readPoint) Creates the scanner for the given read pointprotected org.apache.hadoop.hbase.regionserver.KeyValueScannerKeyValueHeap.pollRealKV()Fetches the top sub-scanner from the priority queue, ensuring that a real seek has been done on it.Methods in org.apache.hadoop.hbase.regionserver that return types with arguments of type org.apache.hadoop.hbase.regionserver.KeyValueScanner in inModifier and TypeMethodDescriptionprotected List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>CompactingMemStore.createList(int capacity) PriorityQueue<org.apache.hadoop.hbase.regionserver.KeyValueScanner>KeyValueHeap.getHeap()Returns the current HeapList<org.apache.hadoop.hbase.regionserver.KeyValueScanner>CompactingMemStore.getScanners(long readPt) This method is protected underHStore#lockread lock.List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>CompositeImmutableSegment.getScanners(long readPoint) List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>DefaultMemStore.getScanners(long readPt) List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>HStore.getScanners(boolean cacheBlocks, boolean isGet, boolean usePread, boolean isCompaction, org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher matcher, byte[] startRow, byte[] stopRow, long readPt, boolean onlyLatestVersion) Get all scanners with no filtering based on TTL (that happens further down the line).List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>HStore.getScanners(boolean cacheBlocks, boolean usePread, boolean isCompaction, org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher matcher, byte[] startRow, boolean includeStartRow, byte[] stopRow, boolean includeStopRow, long readPt, boolean onlyLatestVersion) Get all scanners with no filtering based on TTL (that happens further down the line).List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>HStore.getScanners(List<org.apache.hadoop.hbase.regionserver.HStoreFile> files, boolean cacheBlocks, boolean isGet, boolean usePread, boolean isCompaction, org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher matcher, byte[] startRow, byte[] stopRow, long readPt, boolean includeMemstoreScanner, boolean onlyLatestVersion) Create scanners on the given files and if needed on the memstore with no filtering based on TTL (that happens further down the line).List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>HStore.getScanners(List<org.apache.hadoop.hbase.regionserver.HStoreFile> files, boolean cacheBlocks, boolean usePread, boolean isCompaction, org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher matcher, byte[] startRow, boolean includeStartRow, byte[] stopRow, boolean includeStopRow, long readPt, boolean includeMemstoreScanner, boolean onlyLatestVersion) Create scanners on the given files and if needed on the memstore with no filtering based on TTL (that happens further down the line).List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>MemStore.getScanners(long readPt) List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>MemStoreSnapshot.getScanners()Create newSnapshotSegmentScanners for iterating over the snapshot.List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>Segment.getScanners(long readPoint) List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>HStore.recreateScanners(List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> currentFileScanners, boolean cacheBlocks, boolean usePread, boolean isCompaction, org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher matcher, byte[] startRow, boolean includeStartRow, byte[] stopRow, boolean includeStopRow, long readPt, boolean includeMemstoreScanner) Recreates the scanners on the current list of active store file scannersprotected List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>StoreScanner.selectScannersFrom(org.apache.hadoop.hbase.regionserver.HStore store, List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> allScanners) Filters the given list of scanners using Bloom filter, time range, and TTL.Methods in org.apache.hadoop.hbase.regionserver with parameters of type org.apache.hadoop.hbase.regionserver.KeyValueScanner in inModifier and TypeMethodDescriptionintKeyValueHeap.KVScannerComparator.compare(org.apache.hadoop.hbase.regionserver.KeyValueScanner left, org.apache.hadoop.hbase.regionserver.KeyValueScanner right) static booleanNonLazyKeyValueScanner.doRealSeek(org.apache.hadoop.hbase.regionserver.KeyValueScanner scanner, org.apache.hadoop.hbase.ExtendedCell kv, boolean forward) Method parameters in org.apache.hadoop.hbase.regionserver with type arguments of type org.apache.hadoop.hbase.regionserver.KeyValueScanner in inModifier and TypeMethodDescriptionprotected static voidAbstractMemStore.addToScanners(org.apache.hadoop.hbase.regionserver.Segment segment, long readPt, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners) org.apache.hadoop.hbase.regionserver.RegionScannerImplHRegion.getScanner(org.apache.hadoop.hbase.client.Scan scan, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> additionalScanners) org.apache.hadoop.hbase.regionserver.RegionScannerRegion.getScanner(org.apache.hadoop.hbase.client.Scan scan, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> additionalScanners) Return an iterator that scans over the HRegion, returning the indicated columns and rows specified by theScan.protected voidRegionScannerImpl.initializeKVHeap(List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> joinedScanners, org.apache.hadoop.hbase.regionserver.HRegion region) protected org.apache.hadoop.hbase.regionserver.RegionScannerImplHRegion.instantiateRegionScanner(org.apache.hadoop.hbase.client.Scan scan, List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> additionalScanners, long nonceGroup, long nonce) protected org.apache.hadoop.hbase.regionserver.KeyValueHeapReversedStoreScanner.newKVHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, CellComparator comparator) protected org.apache.hadoop.hbase.regionserver.KeyValueHeapStoreScanner.newKVHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, CellComparator comparator) List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>HStore.recreateScanners(List<org.apache.hadoop.hbase.regionserver.KeyValueScanner> currentFileScanners, boolean cacheBlocks, boolean usePread, boolean isCompaction, org.apache.hadoop.hbase.regionserver.querymatcher.ScanQueryMatcher matcher, byte[] startRow, boolean includeStartRow, byte[] stopRow, boolean includeStopRow, long readPt, boolean includeMemstoreScanner) Recreates the scanners on the current list of active store file scannersprotected voidStoreScanner.resetKVHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, CellComparator comparator) protected voidReversedStoreScanner.seekScanners(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, org.apache.hadoop.hbase.ExtendedCell seekKey, boolean isLazy, boolean isParallelSeek) protected voidStoreScanner.seekScanners(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, org.apache.hadoop.hbase.ExtendedCell seekKey, boolean isLazy, boolean isParallelSeek) Seek the specified scanners with the given keyprotected List<org.apache.hadoop.hbase.regionserver.KeyValueScanner>StoreScanner.selectScannersFrom(org.apache.hadoop.hbase.regionserver.HStore store, List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> allScanners) Filters the given list of scanners using Bloom filter, time range, and TTL.Constructor parameters in org.apache.hadoop.hbase.regionserver with type arguments of type org.apache.hadoop.hbase.regionserver.KeyValueScanner in inModifierConstructorDescriptionKeyValueHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, CellComparator comparator) Constructor.ReversedKeyValueHeap(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, CellComparator comparator) ReversedStoreScanner(org.apache.hadoop.hbase.client.Scan scan, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, NavigableSet<byte[]> columns, List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners) Constructor for testing.StoreScanner(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, long smallestReadPoint, long earliestPutTs, byte[] dropDeletesFromRow, byte[] dropDeletesToRow) Used for compactions that drop deletes from a limited range of rows.StoreScanner(org.apache.hadoop.hbase.regionserver.HStore store, org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, org.apache.hadoop.hbase.regionserver.ScanType scanType, long smallestReadPoint, long earliestPutTs) Used for store file compaction and memstore compaction.StoreScanner(org.apache.hadoop.hbase.regionserver.ScanInfo scanInfo, org.apache.hadoop.hbase.regionserver.ScanType scanType, List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners) -
Uses of org.apache.hadoop.hbase.regionserver.KeyValueScanner in org.apache.hadoop.hbase.util
Classes in org.apache.hadoop.hbase.util that implement org.apache.hadoop.hbase.regionserver.KeyValueScanner in inModifier and TypeClassDescriptionclassorg.apache.hadoop.hbase.util.CollectionBackedScannerUtility scanner that wraps a sortable collection and serves as a KeyValueScanner.