Package org.apache.hadoop.hbase.client

Class SimpleScanResultConsumerImpl

java.lang.Object
org.apache.hadoop.hbase.client.SimpleScanResultConsumerImpl
All Implemented Interfaces:
org.apache.hadoop.hbase.client.ScanResultConsumer, org.apache.hadoop.hbase.client.ScanResultConsumerBase, SimpleScanResultConsumer
Direct Known Subclasses:
LimitedScanResultConsumer
class SimpleScanResultConsumerImpl extends Object implements SimpleScanResultConsumer

  • Field Details

    • scanMetrics

      private org.apache.hadoop.hbase.client.metrics.ScanMetrics scanMetrics

    • results

      protected final List<org.apache.hadoop.hbase.client.Result> results

    • error

      private Throwable error

    • finished

      private boolean finished

  • Constructor Details

  • Method Details

    • onScanMetricsCreated

      public void onScanMetricsCreated(org.apache.hadoop.hbase.client.metrics.ScanMetrics scanMetrics)
      Specified by:
      onScanMetricsCreated in interface org.apache.hadoop.hbase.client.ScanResultConsumerBase

    • onNext

      public boolean onNext(org.apache.hadoop.hbase.client.Result result)
      Specified by:
      onNext in interface org.apache.hadoop.hbase.client.ScanResultConsumer

    • onError

      public void onError(Throwable error)
      Specified by:
      onError in interface org.apache.hadoop.hbase.client.ScanResultConsumerBase

    • onComplete

      public void onComplete()
      Specified by:
      onComplete in interface org.apache.hadoop.hbase.client.ScanResultConsumerBase

    • getAll

      public List<org.apache.hadoop.hbase.client.Result> getAll() throws Exception
      Specified by:
      getAll in interface SimpleScanResultConsumer
      Throws:
      Exception

    • getScanMetrics

      public org.apache.hadoop.hbase.client.metrics.ScanMetrics getScanMetrics()
      Specified by:
      getScanMetrics in interface SimpleScanResultConsumer