Package org.apache.hadoop.hbase.coprocessor.example.row.stats

Class RowStatisticsCompactionObserver.RowStatisticsScanner

java.lang.Object

org.apache.hadoop.hbase.coprocessor.example.row.stats.RowStatisticsCompactionObserver.RowStatisticsScanner

All Implemented Interfaces:

Closeable, AutoCloseable, InternalScanner, Shipper

Enclosing class:

RowStatisticsCompactionObserver

private static class RowStatisticsCompactionObserver.RowStatisticsScanner
extends Object
implements InternalScanner, Shipper

Field Summary

Fields

Modifier and Type	Field	Description
private RawCellBuilder	cellBuilder
private final RowStatisticsRecorder	customRecorder
private Cell	lastCell
private final RegionCoprocessorEnvironment	regionEnv
private final RowStatisticsImpl	rowStatistics
private final Counter	rowStatisticsDropped
private final Counter	rowStatisticsPutFailed
private final InternalScanner	scanner
private final Shipper	shipper

Constructor Summary

Constructors

Constructor	Description
RowStatisticsScanner(InternalScanner scanner, RowStatisticsImpl rowStatistics, RegionCoprocessorEnvironment regionEnv, RowStatisticsRecorder customRecorder)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the scanner and releases any resources it has allocated
private void	consumeCells(List<? super ExtendedCell> result)
boolean	next(List<? super ExtendedCell> result)	Grab the next row's worth of values.
boolean	next(List<? super ExtendedCell> result, ScannerContext scannerContext)	Grab the next row's worth of values.
private void	record()
private boolean	rowChanged(Cell cell)
void	shipped()	Called after a batch of rows scanned and set to be returned to client.

Methods inherited from class java.lang.Object

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

Field Details

scanner

private final InternalScanner scanner

shipper

private final Shipper shipper

rowStatistics

private final RowStatisticsImpl rowStatistics

regionEnv

private final RegionCoprocessorEnvironment regionEnv

rowStatisticsDropped

private final Counter rowStatisticsDropped

rowStatisticsPutFailed

private final Counter rowStatisticsPutFailed

customRecorder

private final RowStatisticsRecorder customRecorder

cellBuilder

private RawCellBuilder cellBuilder

lastCell

private Cell lastCell

Constructor Details

RowStatisticsScanner

public RowStatisticsScanner(InternalScanner scanner,
 RowStatisticsImpl rowStatistics,
 RegionCoprocessorEnvironment regionEnv,
 RowStatisticsRecorder customRecorder)

Method Details

next

public boolean next(List<? super ExtendedCell> result,
 ScannerContext scannerContext)
             throws IOException

Description copied from interface: InternalScanner

Grab the next row's worth of values.

The generic type for the output list result means we will only add ExtendedCell to it. This is useful for the code in HBase as we can pass List<ExtendedCell> here to avoid casting, but may cause some troubles for coprocessors which implement this method. In general, all cells created via the CellBuilder are actually ExtendedCells, so if you want to add something to the result list, you can just cast it to ExtendedCell, although it is marked as IA.Private.

Specified by:

next in interface InternalScanner

Parameters:

result - return output array. We will only add ExtendedCell to this list, but for CP users, you'd better just use RawCell as ExtendedCell is IA.Private.

Returns:

true if more rows exist after this one, false if scanner is done

Throws:

IOException

next

public boolean next(List<? super ExtendedCell> result)
             throws IOException

Description copied from interface: InternalScanner

Grab the next row's worth of values.

The generic type for the output list result means we will only add ExtendedCell to it. This is useful for the code in HBase as we can pass List<ExtendedCell> here to avoid casting, but may cause some troubles for coprocessors which implement this method. In general, all cells created via the CellBuilder are actually ExtendedCells, so if you want to add something to the result list, you can just cast it to ExtendedCell, although it is marked as IA.Private.

Specified by:

next in interface InternalScanner

Parameters:

result - return output array. We will only add ExtendedCell to this list, but for CP users, you'd better just use RawCell as ExtendedCell is IA.Private.

Returns:

true if more rows exist after this one, false if scanner is done

Throws:

IOException

close

public void close()
           throws IOException

Description copied from interface: InternalScanner

Closes the scanner and releases any resources it has allocated

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface InternalScanner

Throws:

IOException

shipped

public void shipped()
             throws IOException

Description copied from interface: Shipper

Called after a batch of rows scanned and set to be returned to client. Any in between cleanup can be done here.

Specified by:

shipped in interface Shipper

Throws:

IOException

consumeCells

private void consumeCells(List<? super ExtendedCell> result)

rowChanged

private boolean rowChanged(Cell cell)

record

private void record()