com.google.cloud.bigtable.grpc.async
Class BulkRead
- java.lang.Object
-
- com.google.cloud.bigtable.grpc.async.BulkRead
-
public class BulkRead extends Object
This class combines a collection ofReadRowsRequests with a single row key into a singleReadRowsRequestwith aRowSetwhich will result in fewer round trips. This class is not thread safe, and requires calling classes to make it thread safe.- Version:
- $Id: $Id
- Author:
- sduskis
-
-
Field Summary
Fields Modifier and Type Field and Description protected static LoggerLOGConstantLOG
-
Constructor Summary
Constructors Constructor and Description BulkRead(IBigtableDataClient client, BigtableTableName tableName, int batchSizes, ExecutorService threadPool)Constructor for BulkRead.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method and Description com.google.api.core.ApiFuture<FlatRow>add(com.google.cloud.bigtable.data.v2.models.Query query)Adds the key in the request to a batch read.voidflush()Sends all remaining requests to the server.intgetBatchSizes()
-
-
-
Field Detail
-
LOG
protected static final Logger LOG
ConstantLOG
-
-
Constructor Detail
-
BulkRead
public BulkRead(IBigtableDataClient client, BigtableTableName tableName, int batchSizes, ExecutorService threadPool)
Constructor for BulkRead.- Parameters:
client- aIBigtableDataClientobject.tableName- aBigtableTableNameobject.batchSizes- The number of keys to lookup per RPC.threadPool- theExecutorServiceto execute the batched reads on
-
-
Method Detail
-
add
public com.google.api.core.ApiFuture<FlatRow> add(com.google.cloud.bigtable.data.v2.models.Query query)
Adds the key in the request to a batch read. The future will be resolved when the batch response is received.- Parameters:
query- aQuerywith a single row key.- Returns:
- a
ApiFuturethat will be populated with theFlatRowthat corresponds to the request
-
flush
public void flush()
Sends all remaining requests to the server. This method does not wait for the method to complete.
-
getBatchSizes
public int getBatchSizes()
-
-