Package | Description |
---|---|
com.google.cloud.bigtable.data.v2 |
A client for the Cloud Bigtable data API.
|
com.google.cloud.bigtable.data.v2.models | |
com.google.cloud.bigtable.data.v2.stub | |
com.google.cloud.bigtable.data.v2.stub.metrics |
Modifier and Type | Method and Description |
---|---|
com.google.api.gax.rpc.UnaryCallable<Query,Row> |
BigtableDataClient.readRowCallable()
Reads a single row.
|
<RowT> com.google.api.gax.rpc.UnaryCallable<Query,RowT> |
BigtableDataClient.readRowCallable(RowAdapter<RowT> rowAdapter)
Reads a single row.
|
com.google.api.gax.rpc.ServerStreamingCallable<Query,Row> |
BigtableDataClient.readRowsCallable()
Streams back the results of the query.
|
<RowT> com.google.api.gax.rpc.ServerStreamingCallable<Query,RowT> |
BigtableDataClient.readRowsCallable(RowAdapter<RowT> rowAdapter)
Streams back the results of the query.
|
com.google.api.gax.rpc.UnaryCallSettings<Query,Row> |
BigtableDataSettings.readRowSettings()
Returns the object with the settings used for point reads via ReadRow.
|
Modifier and Type | Method and Description |
---|---|
com.google.api.gax.rpc.ServerStream<Row> |
BigtableDataClient.readRows(Query query)
Convenience method for synchronously streaming the results of a
Query . |
void |
BigtableDataClient.readRowsAsync(Query query,
com.google.api.gax.rpc.ResponseObserver<Row> observer)
Convenience method for asynchronously streaming the results of a
Query . |
Modifier and Type | Method and Description |
---|---|
static Query |
Query.create(String tableId)
Constructs a new Query object for the specified table id.
|
Query |
Query.filter(Filters.Filter filter)
Sets the filter to apply to each row.
|
static Query |
Query.fromProto(ReadRowsRequest request)
Wraps the protobuf
ReadRowsRequest . |
Query |
Query.limit(long limit)
Limits the number of rows that can be returned
|
Query |
Query.prefix(ByteString prefix) |
Query |
Query.prefix(String prefix) |
Query |
Query.range(ByteString start,
ByteString end)
Adds a range to be looked up.
|
Query |
Query.range(Range.ByteStringRange range)
Adds a range to be looked up.
|
Query |
Query.range(String start,
String end)
Adds a range to be looked up.
|
Query |
Query.rowKey(ByteString key)
Adds a key to looked up
|
Query |
Query.rowKey(String key)
Adds a key to looked up
|
Modifier and Type | Method and Description |
---|---|
List<Query> |
Query.shard(List<KeyOffset> sampledRowKeys)
Split this query into multiple queries that can be evenly distributed across Bigtable nodes and
be run in parallel.
|
List<Query> |
Query.shard(SortedSet<ByteString> splitPoints)
Split this query into multiple queries that logically combine into this query.
|
Modifier and Type | Method and Description |
---|---|
com.google.api.gax.rpc.UnaryCallSettings<Query,Row> |
EnhancedBigtableStubSettings.readRowSettings()
Returns the object with the settings used for point reads via ReadRows.
|
com.google.api.gax.rpc.UnaryCallSettings.Builder<Query,Row> |
EnhancedBigtableStubSettings.Builder.readRowSettings()
Returns the builder for the settings used for point reads using readRow.
|
com.google.api.gax.rpc.ServerStreamingCallSettings<Query,Row> |
EnhancedBigtableStubSettings.readRowsSettings()
Returns the object with the settings used for calls to ReadRows.
|
com.google.api.gax.rpc.ServerStreamingCallSettings.Builder<Query,Row> |
EnhancedBigtableStubSettings.Builder.readRowsSettings()
Returns the builder for the settings used for calls to readRows.
|
Modifier and Type | Method and Description |
---|---|
void |
MeasuredReadRowsCallable.call(Query request,
com.google.api.gax.rpc.ResponseObserver<RowT> outerObserver,
com.google.api.gax.rpc.ApiCallContext context) |
Constructor and Description |
---|
MeasuredReadRowsCallable(com.google.api.gax.rpc.ServerStreamingCallable<Query,RowT> innerCallable,
String methodName,
io.opencensus.tags.Tagger tagger,
io.opencensus.stats.StatsRecorder stats,
com.google.api.core.ApiClock clock) |
Copyright © 2019 Google LLC. All rights reserved.