Class Query (2.35.1)

A simple wrapper to construct a query for the ReadRows RPC.

Constructs a new Query object for the specified table id. The table id will be combined with the instance name specified in the com.google.cloud.bigtable.data.v2.BigtableDataSettings.

Wraps the protobuf ReadRowsRequest.

WARNING: Please note that the project id & instance id in the table name will be overwritten by the configuration in the BigtableDataClient.

Create a query paginator that'll split the query into smaller chunks.

Example usage:

 Query query = Query.create(...).range("a", "z");
 Query.QueryPaginator paginator = query.createQueryPaginator(100);
 ByteString lastSeenRowKey = ByteString.EMPTY;
 do {
     List<Row> rows = client.readRowsCallable().all().call(paginator.getNextQuery());
     for (Row row : rows) {
        // do some processing
        lastSeenRow = row;
     }
 } while (paginator.advance(lastSeenRowKey));
 

Sets the filter to apply to each row. Only one filter can be set at a time. To use multiple filters, please use Filters#interleave() or Filters#chain().

Get the minimal range that encloses all of the row keys and ranges in this Query.

Limits the number of rows that can be returned

Adds a range to be looked up.

Adds a range to be looked up.

Adds a range to be looked up.

Return rows in reverse order.

The row will be streamed in reverse lexiographic order of the keys. The row key ranges are still expected to be oriented the same way as forwards. ie [a,c] where a <= c. The row content will remain unchanged from the ordering forward scans. This is particularly useful to get the last N records before a key:

 query
   .range(ByteStringRange.unbounded().endOpen("key"))
   .limit(10)
   .reversed(true)
 

Adds a key to looked up

Adds a key to looked up

Split this query into multiple queries that can be evenly distributed across Bigtable nodes and be run in parallel. This method takes the results from com.google.cloud.bigtable.data.v2.BigtableDataClient#sampleRowKeysAsync(String) to divide this query into a set of disjoint queries that logically combine into form this query.

Expected Usage:

 List<KeyOffset> keyOffsets = dataClient.sampleRowKeysAsync("my-table").get();
 List<Query> queryShards = myQuery.shard(keyOffsets);
 List

Split this query into multiple queries that logically combine into this query. This is intended to be used by map reduce style frameworks like Beam to split a query across multiple workers.

Expected Usage:

 List<ByteString> splitPoints = ...;
 List<Query> queryShards = myQuery.shard(splitPoints);
 List

Creates the request protobuf. This method is considered an internal implementation detail and not meant to be used by applications.