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) 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) 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) 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) 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.Cell 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 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.Cell seekKey, boolean isLazy, boolean isParallelSeek) protected voidStoreScanner.seekScanners(List<? extends org.apache.hadoop.hbase.regionserver.KeyValueScanner> scanners, org.apache.hadoop.hbase.Cell 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.