Serialized Form

Package com.google.cloud.bigtable.beam

Class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn extends DoFn<In,Out> implements Serializable

serialVersionUID:

1L

Serialized Fields

config

CloudBigtableConfiguration config

connection

Connection connection

DOFN_LOG

org.slf4j.Logger DOFN_LOG

Class com.google.cloud.bigtable.beam.CloudBigtableConfiguration extends Object implements Serializable

serialVersionUID:

1655181275627002133L

Serialized Fields

configuration

Map<String,ValueProvider<String>> configuration

Class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableMultiTableWriteFn extends com.google.cloud.bigtable.beam.CloudBigtableIO.BufferedMutatorDoFn<KV<String,Iterable<Mutation>>> implements Serializable

serialVersionUID:

2L

Class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableSingleTableBufferedWriteFn extends com.google.cloud.bigtable.beam.CloudBigtableIO.BufferedMutatorDoFn<Mutation> implements Serializable

serialVersionUID:

2L

Class com.google.cloud.bigtable.beam.CloudBigtableIO.Source extends com.google.cloud.bigtable.beam.CloudBigtableIO.AbstractSource implements Serializable

serialVersionUID:

-5580115943635114126L

Class com.google.cloud.bigtable.beam.CloudBigtableIO.SourceWithKeys extends com.google.cloud.bigtable.beam.CloudBigtableIO.AbstractSource implements Serializable

serialVersionUID:

1L

Serialized Fields

estimatedSize

long estimatedSize

An estimate of the size of the source, in bytes.

NOTE: This value is a guesstimate. It could be significantly off, especially if there is a Scan selected in the configuration. It will also be off if the start and stop keys are calculated via CloudBigtableIO.Source.split(long, PipelineOptions).

Class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration extends CloudBigtableTableConfiguration implements Serializable

serialVersionUID:

2435897354284600685L

Serialized Fields

request

ValueProvider<com.google.bigtable.repackaged.com.google.bigtable.v2.ReadRowsRequest> request

Class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration extends CloudBigtableConfiguration implements Serializable

serialVersionUID:

2435897354284600685L

Serialized Fields

tableId

ValueProvider<String> tableId