com.google.cloud.bigtable.data.v2.stub.readrows

Class RowMerger<RowT>

java.lang.Object

com.google.cloud.bigtable.data.v2.stub.readrows.RowMerger<RowT>

All Implemented Interfaces:

Reframer<RowT,com.google.bigtable.v2.ReadRowsResponse>

@InternalApi
public class RowMerger<RowT>
extends Object
implements Reframer<RowT,com.google.bigtable.v2.ReadRowsResponse>

An implementation of a Reframer that feeds the row merging StateMachine.

ReframingResponseObserver pushes ReadRowsResponse.CellChunks into this class and pops fully merged logical rows. Example usage:

 RowMerger<Row> rowMerger = new RowMerger<>(myRowBuilder);

 while(responseIterator.hasNext()) {
   ReadRowsResponse response = responseIterator.next();

   if (rowMerger.hasFullFrame()) {
     Row row = rowMerger.pop();
     // Do something with row.
   } else {
     rowMerger.push(response);
   }
 }

 if (rowMerger.hasPartialFrame()) {
   throw new RuntimeException("Incomplete stream");
 }

 

This class is considered an internal implementation detail and not meant to be used by applications.

Package-private for internal use.

See Also:

for more details

Constructor Summary

Constructors

Constructor and Description
RowMerger(RowAdapter.RowBuilder<RowT> rowBuilder)

Method Summary

Modifier and Type	Method and Description
boolean	hasFullFrame() Checks if there is a frame to be popped.
boolean	hasPartialFrame() Checks if there is any incomplete data.
RowT	pop() Returns and removes the current completed frame.
void	push(com.google.bigtable.v2.ReadRowsResponse response) Refill internal buffers with inner/upstream response.

Methods inherited from class java.lang.Object

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

Constructor Detail

RowMerger

public RowMerger(RowAdapter.RowBuilder<RowT> rowBuilder)

Method Detail

push

public void push(com.google.bigtable.v2.ReadRowsResponse response)

Description copied from interface: Reframer

Refill internal buffers with inner/upstream response. Should only be invoked if Reframer.hasFullFrame() returns false.

Specified by:

push in interface Reframer<RowT,com.google.bigtable.v2.ReadRowsResponse>

hasFullFrame

public boolean hasFullFrame()

Description copied from interface: Reframer

Checks if there is a frame to be popped.

Note that this method might update internal to buffer the next response.

Specified by:

hasFullFrame in interface Reframer<RowT,com.google.bigtable.v2.ReadRowsResponse>

hasPartialFrame

public boolean hasPartialFrame()

Description copied from interface: Reframer

Checks if there is any incomplete data. Used to check if the stream closed prematurely.

Specified by:

hasPartialFrame in interface Reframer<RowT,com.google.bigtable.v2.ReadRowsResponse>

pop

public RowT pop()

Description copied from interface: Reframer

Returns and removes the current completed frame. Should only be called if hasFullFrame returns true.

Specified by:

pop in interface Reframer<RowT,com.google.bigtable.v2.ReadRowsResponse>