Uses of Interface
org.apache.hadoop.hbase.regionserver.InternalScanner
Packages that use InternalScanner
Package
Description
Table of Contents
-
Uses of InternalScanner in org.apache.hadoop.hbase.coprocessor
Methods in org.apache.hadoop.hbase.coprocessor that return InternalScannerModifier and TypeMethodDescriptiondefault InternalScannerRegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) Called prior to writing theStoreFiles selected for compaction into a newStoreFile.default InternalScannerRegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) Called before a Store's memstore is flushed to disk.default InternalScannerRegionObserver.preMemStoreCompactionCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner) Called before we do in memory compaction.Methods in org.apache.hadoop.hbase.coprocessor with parameters of type InternalScannerModifier and TypeMethodDescriptiondefault voidRegionObserver.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> ctx, InternalScanner s) Called after the client closes a scanner.default booleanRegionObserver.postScannerFilterRow(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, Cell curRowCell, boolean hasMore) This will be called by the scan flow when the current scanned row is being filtered out by the filter.default booleanRegionObserver.postScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext) Called after the client asks for the next row on a scanner.default InternalScannerRegionObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) Called prior to writing theStoreFiles selected for compaction into a newStoreFile.default InternalScannerRegionObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) Called before a Store's memstore is flushed to disk.default InternalScannerRegionObserver.preMemStoreCompactionCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner) Called before we do in memory compaction.default voidRegionObserver.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) Called before the client closes a scanner.default booleanRegionObserver.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext) Called before the client asks for the next row on a scanner. -
Uses of InternalScanner in org.apache.hadoop.hbase.coprocessor.example
Classes in org.apache.hadoop.hbase.coprocessor.example that implement InternalScannerModifier and TypeClassDescriptionclassA simple delegation for doing filtering onInternalScanner.Fields in org.apache.hadoop.hbase.coprocessor.example declared as InternalScannerModifier and TypeFieldDescriptionprotected final InternalScannerDelegatingInternalScanner.scannerMethods in org.apache.hadoop.hbase.coprocessor.example that return InternalScannerModifier and TypeMethodDescriptionValueRewritingObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) WriteHeavyIncrementObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) WriteHeavyIncrementObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) WriteHeavyIncrementObserver.preMemStoreCompactionCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner) private InternalScannerWriteHeavyIncrementObserver.wrap(byte[] family, InternalScanner scanner) Methods in org.apache.hadoop.hbase.coprocessor.example with parameters of type InternalScannerModifier and TypeMethodDescriptionValueRewritingObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) WriteHeavyIncrementObserver.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) WriteHeavyIncrementObserver.preFlush(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) WriteHeavyIncrementObserver.preMemStoreCompactionCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner) private InternalScannerWriteHeavyIncrementObserver.wrap(byte[] family, InternalScanner scanner) Constructors in org.apache.hadoop.hbase.coprocessor.example with parameters of type InternalScanner -
Uses of InternalScanner in org.apache.hadoop.hbase.mob
Methods in org.apache.hadoop.hbase.mob with parameters of type InternalScannerModifier and TypeMethodDescriptionprotected booleanDefaultMobStoreCompactor.performCompaction(Compactor.FileDetails fd, InternalScanner scanner, CellSink writer, long smallestReadPoint, boolean cleanSeqId, ThroughputController throughputController, CompactionRequestImpl request, CompactionProgress progress) Performs compaction on a column family with the mob flag enabled.protected voidDefaultMobStoreFlusher.performMobFlush(MemStoreSnapshot snapshot, long cacheFlushId, InternalScanner scanner, StoreFileWriter writer, MonitoredTask status, ThroughputController throughputController, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker) Flushes the cells in the mob store. -
Uses of InternalScanner in org.apache.hadoop.hbase.regionserver
Subinterfaces of InternalScanner in org.apache.hadoop.hbase.regionserverModifier and TypeInterfaceDescriptioninterfaceRegionScanner describes iterators over rows in an HRegion.Classes in org.apache.hadoop.hbase.regionserver that implement InternalScannerModifier and TypeClassDescriptionclassImplements a heap merge across any number of KeyValueScanners.classScanner scans both the memstore and the MOB Store.(package private) classRegionScannerImpl is used to combine scanners from multiple Stores (aka column families).classReversedKeyValueHeap is used for supporting reversed scanning.classReversedMobStoreScanner extends from ReversedStoreScanner, and is used to support reversed scanning in both the memstore and the MOB store.(package private) classReversibleRegionScannerImpl extends from RegionScannerImpl, and is used to support reversed scanning.classReversedStoreScanner extends from StoreScanner, and is used to support reversed scanning.classScanner scans both the memstore and the Store.Fields in org.apache.hadoop.hbase.regionserver declared as InternalScannerModifier and TypeFieldDescriptionprivate InternalScannerMemStoreCompactorSegmentsIterator.compactingScannerMethods in org.apache.hadoop.hbase.regionserver that return InternalScannerModifier and TypeMethodDescriptionprivate InternalScannerMemStoreCompactorSegmentsIterator.createScanner(HStore store, List<KeyValueScanner> scanners) Creates the scanner for compacting the pipeline.protected final InternalScannerStoreFlusher.createScanner(List<KeyValueScanner> snapshotScanners, FlushLifeCycleTracker tracker) Creates the scanner for flushing snapshot.RegionCoprocessorHost.preCompact(HStore store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request, User user) Called prior to rewriting the store files selected for compactionRegionCoprocessorHost.preFlush(HStore store, InternalScanner scanner, FlushLifeCycleTracker tracker) Invoked before a memstore flushRegionCoprocessorHost.preMemStoreCompactionCompact(HStore store, InternalScanner scanner) Invoked before compacting memstore.Methods in org.apache.hadoop.hbase.regionserver with parameters of type InternalScannerModifier and TypeMethodDescriptionprotected voidStoreFlusher.performFlush(InternalScanner scanner, CellSink sink, ThroughputController throughputController) Performs memstore flush, writing data from scanner into sink.voidRegionCoprocessorHost.postScannerClose(InternalScanner s) booleanRegionCoprocessorHost.postScannerFilterRow(InternalScanner s, Cell curRowCell) This will be called by the scan flow when the current scanned row is being filtered out by the filter.booleanRegionCoprocessorHost.postScannerNext(InternalScanner s, List<Result> results, int limit, boolean hasMore) RegionCoprocessorHost.preCompact(HStore store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request, User user) Called prior to rewriting the store files selected for compactionRegionCoprocessorHost.preFlush(HStore store, InternalScanner scanner, FlushLifeCycleTracker tracker) Invoked before a memstore flushRegionCoprocessorHost.preMemStoreCompactionCompact(HStore store, InternalScanner scanner) Invoked before compacting memstore.booleanRegionCoprocessorHost.preScannerClose(InternalScanner s) Supports Coprocessor 'bypass'.RegionCoprocessorHost.preScannerNext(InternalScanner s, List<Result> results, int limit) -
Uses of InternalScanner in org.apache.hadoop.hbase.regionserver.compactions
Methods in org.apache.hadoop.hbase.regionserver.compactions that return InternalScannerModifier and TypeMethodDescriptionprotected InternalScannerCompactor.createScanner(HStore store, ScanInfo scanInfo, List<StoreFileScanner> scanners, long smallestReadPoint, long earliestPutTs, byte[] dropDeletesFromRow, byte[] dropDeletesToRow) protected InternalScannerCompactor.createScanner(HStore store, ScanInfo scanInfo, List<StoreFileScanner> scanners, ScanType scanType, long smallestReadPoint, long earliestPutTs) Compactor.InternalScannerFactory.createScanner(ScanInfo scanInfo, List<StoreFileScanner> scanners, ScanType scanType, Compactor.FileDetails fd, long smallestReadPoint) StripeCompactor.StripeInternalScannerFactory.createScanner(ScanInfo scanInfo, List<StoreFileScanner> scanners, ScanType scanType, Compactor.FileDetails fd, long smallestReadPoint) private InternalScannerCompactor.postCompactScannerOpen(CompactionRequestImpl request, ScanType scanType, InternalScanner scanner, User user) Calls coprocessor, if any, to create scanners - after normal scanner creation.Methods in org.apache.hadoop.hbase.regionserver.compactions with parameters of type InternalScannerModifier and TypeMethodDescriptionCompactor.CellSinkFactory.createWriter(InternalScanner scanner, Compactor.FileDetails fd, boolean shouldDropBehind, boolean major, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker) protected final voidAbstractMultiOutputCompactor.initMultiWriter(AbstractMultiFileWriter writer, InternalScanner scanner, Compactor.FileDetails fd, boolean shouldDropBehind, boolean major, Consumer<org.apache.hadoop.fs.Path> writerCreationTracker) protected booleanCompactor.performCompaction(Compactor.FileDetails fd, InternalScanner scanner, CellSink writer, long smallestReadPoint, boolean cleanSeqId, ThroughputController throughputController, CompactionRequestImpl request, CompactionProgress progress) Performs the compaction.private InternalScannerCompactor.postCompactScannerOpen(CompactionRequestImpl request, ScanType scanType, InternalScanner scanner, User user) Calls coprocessor, if any, to create scanners - after normal scanner creation. -
Uses of InternalScanner in org.apache.hadoop.hbase.security.access
Fields in org.apache.hadoop.hbase.security.access with type parameters of type InternalScannerModifier and TypeFieldDescriptionprivate Map<InternalScanner,String> AccessController.scannerOwnersMapping of scanner instances to the user who created themMethods in org.apache.hadoop.hbase.security.access that return InternalScannerModifier and TypeMethodDescriptionAccessController.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) Methods in org.apache.hadoop.hbase.security.access with parameters of type InternalScannerModifier and TypeMethodDescriptionvoidAccessController.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) AccessController.preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) voidAccessController.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) booleanAccessController.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext) private voidAccessController.requireScannerOwner(InternalScanner s) Verify, when servicing an RPC, that the caller is the scanner owner. -
Uses of InternalScanner in org.apache.hadoop.hbase.security.visibility
Fields in org.apache.hadoop.hbase.security.visibility with type parameters of type InternalScannerModifier and TypeFieldDescriptionprivate Map<InternalScanner,String> VisibilityController.scannerOwnersMapping of scanner instances to the user who created themMethods in org.apache.hadoop.hbase.security.visibility with parameters of type InternalScannerModifier and TypeMethodDescriptionvoidVisibilityController.postScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) voidVisibilityController.preScannerClose(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s) booleanVisibilityController.preScannerNext(ObserverContext<RegionCoprocessorEnvironment> c, InternalScanner s, List<Result> result, int limit, boolean hasNext) private voidVisibilityController.requireScannerOwner(InternalScanner s) Verify, when servicing an RPC, that the caller is the scanner owner.