RowMerger (Cloud Bigtable HBase Client for Java 0.9.3-SNAPSHOT API)

com.google.cloud.bigtable.grpc.scanner

Class RowMerger

  • All Implemented Interfaces:
    io.grpc.stub.StreamObserver<ReadRowsResponse>


    public class RowMerger
    extends Object
    implements io.grpc.stub.StreamObserver<ReadRowsResponse>

    Builds a complete Row from ReadRowsResponse objects. A ReadRowsResponse may contain a single Row, multiple Rows, or even a part of a Cell if the cell is

    Each RowMerger object is valid only for building a single Row. Expected usage is along the lines of:

     StreamObserver<Row> observer = ...;
     RowMerger rowMerger = new RowMerger(observer);
     ...
     rowMerger.onNext(...);
     ..
     rowMerger.onComplete();
     

    When a complete row is found, StreamObserver.onNext(Object) will be called. StreamObserver.onError(Throwable) will be called for

    Version:
    $Id: $Id
    Author:
    sduskis
    • Constructor Detail

      • RowMerger

        public RowMerger(io.grpc.stub.StreamObserver<Row> observer)

        Constructor for RowMerger.

        Parameters:
        observer - a StreamObserver object.


Send feedback about...

Cloud Bigtable Documentation