public static class TestCompactionWithShippingCoprocessor.ShippedObservingScanner extends Object implements org.apache.hadoop.hbase.regionserver.InternalScanner, org.apache.hadoop.hbase.regionserver.Shipper
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.hbase.regionserver.InternalScanner |
scanner |
Constructor and Description |
---|
ShippedObservingScanner(org.apache.hadoop.hbase.regionserver.InternalScanner scanner) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
boolean |
next(List<org.apache.hadoop.hbase.Cell> result,
org.apache.hadoop.hbase.regionserver.ScannerContext scannerContext) |
void |
shipped() |
protected final org.apache.hadoop.hbase.regionserver.InternalScanner scanner
public ShippedObservingScanner(org.apache.hadoop.hbase.regionserver.InternalScanner scanner)
public boolean next(List<org.apache.hadoop.hbase.Cell> result, org.apache.hadoop.hbase.regionserver.ScannerContext scannerContext) throws IOException
next
in interface org.apache.hadoop.hbase.regionserver.InternalScanner
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
close
in interface org.apache.hadoop.hbase.regionserver.InternalScanner
IOException
public void shipped() throws IOException
shipped
in interface org.apache.hadoop.hbase.regionserver.Shipper
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.