| Package | Description |
|---|---|
| com.google.cloud.bigtable.beam |
Enables you to use Google Cloud Dataflow to read
from and write to Cloud Bigtable tables.
|
| Modifier and Type | Class | Description |
|---|---|---|
class |
CloudBigtableScanConfiguration |
This class defines configuration that a Cloud Bigtable client needs to connect to a user's Cloud
Bigtable instance; a table to connect to in the instance; and a filter on the table in the form of
a
Scan. |
class |
CloudBigtableTableConfiguration |
This class defines configuration that a Cloud Bigtable client needs to connect to a user's Cloud
Bigtable instance, including a table to connect to in the instance.
|
| Modifier and Type | Field | Description |
|---|---|---|
protected CloudBigtableConfiguration |
AbstractCloudBigtableTableDoFn.config |
| Modifier and Type | Method | Description |
|---|---|---|
CloudBigtableConfiguration |
CloudBigtableConfiguration.Builder.build() |
Builds the
CloudBigtableConfiguration. |
CloudBigtableConfiguration |
AbstractCloudBigtableTableDoFn.getConfig() |
| Modifier and Type | Method | Description |
|---|---|---|
static PTransform<PCollection<KV<String,Iterable<Mutation>>>,PDone> |
CloudBigtableIO.writeToMultipleTables(CloudBigtableConfiguration config) |
Creates a
PTransform that can write either a bounded or unbounded PCollection
of KV of (String tableName, List of Mutations) to the specified table. |
| Constructor | Description |
|---|---|
AbstractCloudBigtableTableDoFn(CloudBigtableConfiguration config) |
|
CloudBigtableMultiTableWriteFn(CloudBigtableConfiguration config) |