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
Methods in org.apache.hadoop.hbase with parameters of type InternalScannerModifier and TypeMethodDescriptionintHBaseTestingUtility.countRows(InternalScanner scanner) Deprecated. -
Uses of InternalScanner in org.apache.hadoop.hbase.coprocessor
Methods in org.apache.hadoop.hbase.coprocessor that return InternalScannerModifier and TypeMethodDescriptiondefault InternalScannerRegionObserver.preCompact(ObserverContext<? extends 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<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) Called before a Store's memstore is flushed to disk.default InternalScannerRegionObserver.preMemStoreCompactionCompact(ObserverContext<? extends 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<? extends RegionCoprocessorEnvironment> ctx, InternalScanner s) Called after the client closes a scanner.default booleanRegionObserver.postScannerFilterRow(ObserverContext<? extends 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<? extends 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<? extends 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<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) Called before a Store's memstore is flushed to disk.default InternalScannerRegionObserver.preMemStoreCompactionCompact(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner) Called before we do in memory compaction.default voidRegionObserver.preScannerClose(ObserverContext<? extends RegionCoprocessorEnvironment> c, InternalScanner s) Called before the client closes a scanner.default booleanRegionObserver.preScannerNext(ObserverContext<? extends 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<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) WriteHeavyIncrementObserver.preCompact(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) WriteHeavyIncrementObserver.preFlush(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) WriteHeavyIncrementObserver.preMemStoreCompactionCompact(ObserverContext<? extends 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<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) WriteHeavyIncrementObserver.preCompact(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) WriteHeavyIncrementObserver.preFlush(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, FlushLifeCycleTracker tracker) WriteHeavyIncrementObserver.preMemStoreCompactionCompact(ObserverContext<? extends 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.coprocessor.example.row.stats
Classes in org.apache.hadoop.hbase.coprocessor.example.row.stats that implement InternalScannerModifier and TypeClassDescriptionprivate static classFields in org.apache.hadoop.hbase.coprocessor.example.row.stats declared as InternalScannerModifier and TypeFieldDescriptionprivate final InternalScannerRowStatisticsCompactionObserver.RowStatisticsScanner.scannerMethods in org.apache.hadoop.hbase.coprocessor.example.row.stats that return InternalScannerModifier and TypeMethodDescriptionRowStatisticsCompactionObserver.preCompact(ObserverContext<? extends RegionCoprocessorEnvironment> context, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) Methods in org.apache.hadoop.hbase.coprocessor.example.row.stats with parameters of type InternalScannerModifier and TypeMethodDescriptionRowStatisticsCompactionObserver.preCompact(ObserverContext<? extends RegionCoprocessorEnvironment> context, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) Constructors in org.apache.hadoop.hbase.coprocessor.example.row.stats with parameters of type InternalScannerModifierConstructorDescriptionRowStatisticsScanner(InternalScanner scanner, RowStatisticsImpl rowStatistics, RegionCoprocessorEnvironment regionEnv, RowStatisticsRecorder customRecorder) -
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.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<? extends 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<? extends RegionCoprocessorEnvironment> c, InternalScanner s) AccessController.preCompact(ObserverContext<? extends RegionCoprocessorEnvironment> c, Store store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request) voidAccessController.preScannerClose(ObserverContext<? extends RegionCoprocessorEnvironment> c, InternalScanner s) booleanAccessController.preScannerNext(ObserverContext<? extends 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<? extends RegionCoprocessorEnvironment> c, InternalScanner s) voidVisibilityController.preScannerClose(ObserverContext<? extends RegionCoprocessorEnvironment> c, InternalScanner s) booleanVisibilityController.preScannerNext(ObserverContext<? extends 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.