ResponseQueueReader (Cloud Bigtable HBase Client for Java 0.9.7.1 API)

com.google.cloud.bigtable.grpc.scanner

Class ResponseQueueReader

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


    public class ResponseQueueReader
    extends Object
    implements io.grpc.stub.StreamObserver<FlatRow>
    Manages a queue of ResultQueueEntrys of FlatRow.
    Version:
    $Id: $Id
    Author:
    sduskis
    See Also:
    for more information.
    • Field Detail

      • resultQueue

        protected final BlockingQueue<com.google.cloud.bigtable.grpc.scanner.ResultQueueEntry<FlatRow>> resultQueue
      • completionMarkerFound

        protected AtomicBoolean completionMarkerFound
    • Constructor Detail

      • ResponseQueueReader

        public ResponseQueueReader(int capacityCap)

        Constructor for ResponseQueueReader.

        Parameters:
        capacityCap - a int.
    • Method Detail

      • getNextMergedRow

        public FlatRow getNextMergedRow()
                                 throws IOException
        Get the next complete FlatRow object from the response queue.
        Returns:
        null if end-of-stream, otherwise a complete FlatRow.
        Throws:
        IOException - On errors.
      • getNext

        protected com.google.cloud.bigtable.grpc.scanner.ResultQueueEntry<FlatRow> getNext()
                                                                                    throws IOException

        getNext.

        Returns:
        a ResultQueueEntry object.
        Throws:
        IOException - if any.
      • available

        public int available()

        available.

        Returns:
        a int.
      • onNext

        public void onNext(FlatRow row)
        Specified by:
        onNext in interface io.grpc.stub.StreamObserver<FlatRow>
      • onError

        public void onError(Throwable t)
        Specified by:
        onError in interface io.grpc.stub.StreamObserver<FlatRow>
      • onCompleted

        public void onCompleted()
        Specified by:
        onCompleted in interface io.grpc.stub.StreamObserver<FlatRow>


Send feedback about...

Cloud Bigtable Documentation