A B C D E F G I L P R S T V W
A
- AbstractCloudBigtableTableDoFn<In,Out> - Class in com.google.cloud.bigtable.beam
-
This class can be used as a superclass for
DoFn
s that require aConnection
in Dataflow. - AbstractCloudBigtableTableDoFn(CloudBigtableConfiguration) - Constructor for class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn
- additionalConfiguration - Variable in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration.Builder
- areParametersAccessible() - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
-
Checks if the parameters are accessible.
B
- build() - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration.Builder
-
Builds the
CloudBigtableConfiguration
. - build() - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Builds the
CloudBigtableScanConfiguration
. - build() - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
-
Builds the
CloudBigtableTableConfiguration
. - Builder() - Constructor for class com.google.cloud.bigtable.beam.CloudBigtableConfiguration.Builder
- Builder() - Constructor for class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
- Builder() - Constructor for class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
C
- checkNotNullOrEmpty(String, String) - Static method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
- CloudBigtableConfiguration - Class in com.google.cloud.bigtable.beam
-
This class defines configuration that a Cloud Bigtable client needs to connect to a Cloud Bigtable instance.
- CloudBigtableConfiguration(ValueProvider<String>, ValueProvider<String>, Map<String, ValueProvider<String>>) - Constructor for class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
-
Creates a
CloudBigtableConfiguration
using the specified project ID and instance ID. - CloudBigtableConfiguration.Builder - Class in com.google.cloud.bigtable.beam
-
Builds a
CloudBigtableConfiguration
. - CloudBigtableIO - Class in com.google.cloud.bigtable.beam
-
Utilities to create
PTransform
s for reading and writing Google Cloud Bigtable entities in a Beam pipeline. - CloudBigtableIO() - Constructor for class com.google.cloud.bigtable.beam.CloudBigtableIO
- CloudBigtableIO.CloudBigtableMultiTableWriteFn - Class in com.google.cloud.bigtable.beam
-
A
DoFn
that can write either a bounded or unboundedPCollection
ofKV
of (String tableName, List ofMutation
s) to the specified table. - CloudBigtableIO.CloudBigtableSingleTableBufferedWriteFn - Class in com.google.cloud.bigtable.beam
-
A
DoFn
that can write either a bounded or unboundedPCollection
ofMutation
s to a table specified via aCloudBigtableTableConfiguration
using the BufferedMutator. - CloudBigtableIO.Source - Class in com.google.cloud.bigtable.beam
- CloudBigtableIO.SourceWithKeys - Class in com.google.cloud.bigtable.beam
-
A
BoundedSource
for a Cloud BigtableTable
with a start/stop key range, along with a potential filter via aScan
. - CloudBigtableMultiTableWriteFn(CloudBigtableConfiguration) - Constructor for class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableMultiTableWriteFn
- CloudBigtableScanConfiguration - Class in com.google.cloud.bigtable.beam
-
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
. - CloudBigtableScanConfiguration(ValueProvider<String>, ValueProvider<String>, ValueProvider<String>, ValueProvider<ReadRowsRequest>, Map<String, ValueProvider<String>>) - Constructor for class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
-
Creates a
CloudBigtableScanConfiguration
using the specified project ID, instance ID, table ID,Scan
and additional connection configuration. - CloudBigtableScanConfiguration.Builder - Class in com.google.cloud.bigtable.beam
-
Builds a
CloudBigtableScanConfiguration
. - CloudBigtableService - Interface in com.google.cloud.bigtable.batch.common
-
This interface describes functionality required by
CloudBigtableIO
that send requests to Cloud Bigtable - CloudBigtableServiceImpl - Class in com.google.cloud.bigtable.batch.common
- CloudBigtableServiceImpl() - Constructor for class com.google.cloud.bigtable.batch.common.CloudBigtableServiceImpl
- CloudBigtableSingleTableBufferedWriteFn(CloudBigtableTableConfiguration) - Constructor for class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableSingleTableBufferedWriteFn
- CloudBigtableTableConfiguration - Class in com.google.cloud.bigtable.beam
-
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.
- CloudBigtableTableConfiguration(ValueProvider<String>, ValueProvider<String>, ValueProvider<String>, Map<String, ValueProvider<String>>) - Constructor for class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration
-
Creates a
CloudBigtableTableConfiguration
using the specified configuration. - CloudBigtableTableConfiguration.Builder - Class in com.google.cloud.bigtable.beam
-
Builds a
CloudBigtableTableConfiguration
. - com.google.cloud.bigtable.batch.common - package com.google.cloud.bigtable.batch.common
-
Google Cloud Bigtable Utilities used by Dataflow.
- com.google.cloud.bigtable.beam - package com.google.cloud.bigtable.beam
-
Enables you to use Google Cloud Dataflow to read from and write to Cloud Bigtable tables.
- config - Variable in class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn
- connection - Variable in class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn
- copyConfig(CloudBigtableConfiguration.Builder) - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
- copyConfig(CloudBigtableScanConfiguration.Builder) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
- copyConfig(CloudBigtableTableConfiguration.Builder) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration
- copyFrom(Map<String, ValueProvider<String>>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration.Builder
D
- DOFN_LOG - Variable in class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn
E
- equals(Object) - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
-
Compares this configuration with the specified object.
- equals(Object) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
- equals(Object) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration
F
- finishBundle(DoFn<KV<String, Iterable<Mutation>>, Void>.FinishBundleContext) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableMultiTableWriteFn
- finishBundle(DoFn<Mutation, Void>.FinishBundleContext) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableSingleTableBufferedWriteFn
-
Closes the
BufferedMutator
andConnection
. - fromConfig(CloudBigtableTableConfiguration, Scan) - Static method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
-
Converts a
CloudBigtableTableConfiguration
object to aCloudBigtableScanConfiguration
that will perform the specifiedScan
on the table.
G
- getAppProfileId() - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
-
Get the Cloud Bigtable App Profile id.
- getConfig() - Method in class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn
- getConfiguration() - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
-
Gets an immutable copy of the configuration map.
- getConnection() - Method in class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn
- getDisplayValue(ValueProvider<T>) - Static method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
- getEstimatedSize() - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.SourceWithKeys
- getEstimatedSizeBytes(PipelineOptions) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.Source
-
Gets an estimated size based on data returned from
CloudBigtableServiceImpl.getSampleRowKeys(CloudBigtableTableConfiguration)
. - getEstimatedSizeBytes(PipelineOptions) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.SourceWithKeys
-
Gets an estimate of the size of the source.
- getInstanceId() - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
-
Gets the Cloud Bigtable instance id.
- getOutputCoder() - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.Source
- getOutputCoder() - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.SourceWithKeys
- getProjectId() - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
-
Gets the project ID for the Cloud Bigtable instance.
- getRequest() - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
-
Gets the
Scan
used to filter the table. - getSampleRowKeys(CloudBigtableTableConfiguration) - Method in interface com.google.cloud.bigtable.batch.common.CloudBigtableService
- getSampleRowKeys(CloudBigtableTableConfiguration) - Method in class com.google.cloud.bigtable.batch.common.CloudBigtableServiceImpl
- getStartRow() - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
- getStopRow() - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
- getTableId() - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration
-
Gets the table specified by the configuration.
I
- instanceId - Variable in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration.Builder
L
- logExceptions(Object, RetriesExhaustedWithDetailsException) - Method in class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn
-
Logs a context and the exception's
RetriesExhaustedWithDetailsException.getExhaustiveDescription()
. - logRetriesExhaustedWithDetailsException(Logger, String, RetriesExhaustedWithDetailsException) - Static method in class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn
P
- PLACEHOLDER_APP_PROFILE_ID - Static variable in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
- PLACEHOLDER_INSTANCE_ID - Static variable in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
- PLACEHOLDER_PROJECT_ID - Static variable in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
- PLACEHOLDER_TABLE_ID - Static variable in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
- populateDisplayData(DisplayData.Builder) - Method in class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn
- populateDisplayData(DisplayData.Builder) - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
- populateDisplayData(DisplayData.Builder) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
- populateDisplayData(DisplayData.Builder) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration
- processElement(DoFn<KV<String, Iterable<Mutation>>, Void>.ProcessContext) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableMultiTableWriteFn
- processElement(DoFn<Mutation, Void>.ProcessContext) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableSingleTableBufferedWriteFn
-
Performs an asynchronous mutation via
BufferedMutator.mutate(Mutation)
. - projectId - Variable in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration.Builder
R
- read(CloudBigtableScanConfiguration) - Static method in class com.google.cloud.bigtable.beam.CloudBigtableIO
- rethrowException(RetriesExhaustedWithDetailsException) - Static method in class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn
S
- setupBufferedMutator(DoFn<Mutation, Void>.StartBundleContext) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableSingleTableBufferedWriteFn
- SourceWithKeys(CloudBigtableScanConfiguration, long) - Constructor for class com.google.cloud.bigtable.beam.CloudBigtableIO.SourceWithKeys
- split(long, PipelineOptions) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.Source
-
Splits the table based on keys that belong to tablets, known as "regions" in the HBase API.
- split(long, PipelineOptions) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.SourceWithKeys
-
Splits the bundle based on the assumption that the data is distributed evenly between startKey and stopKey.
- startBundle() - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableMultiTableWriteFn
T
- tableId - Variable in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
- tableId - Variable in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration
- toBigtableOptions() - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
-
Converts the
CloudBigtableConfiguration
to aBigtableOptions
object. - toBuilder() - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
-
Creates a new
CloudBigtableConfiguration.Builder
object containing the existing configuration. - toBuilder() - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
- toBuilder() - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration
- toByteKeyRange() - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration
-
Creates a
ByteKeyRange
representing the start and stop keys for this instance. - toHBaseConfig() - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
-
Converts the
CloudBigtableConfiguration
to an HBaseConfiguration
. - toString() - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.SourceWithKeys
V
- validate() - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
- validate() - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration
- VALUE_UNAVAILABLE - Static variable in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration
W
- withAppProfileId(String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration.Builder
-
Specifies the AppProfile to use.
- withAppProfileId(String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Specifies the AppProfile to use.
- withAppProfileId(ValueProvider<String>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Specifies the AppProfile to use.
- withAppProfileId(String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
-
Specifies the AppProfile to use.
- withAppProfileId(ValueProvider<String>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
-
Specifies the AppProfile to use.
- withConfiguration(String, String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration.Builder
-
Adds additional connection configuration.
- withConfiguration(String, String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Adds additional connection configuration.
- withConfiguration(String, ValueProvider<String>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Adds additional connection configuration.
- withConfiguration(String, String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
-
Adds additional connection configuration.
- withConfiguration(String, ValueProvider<String>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
-
Adds additional connection configuration.
- withInstanceId(String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration.Builder
-
Specifies the Cloud Bigtable instanceId.
- withInstanceId(String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Specifies the Cloud Bigtable instanceId.
- withInstanceId(ValueProvider<String>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Specifies the Cloud Bigtable instanceId.
- withInstanceId(String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
-
Specifies the Cloud Bigtable instanceId.
- withInstanceId(ValueProvider<String>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
-
Specifies the Cloud Bigtable instanceId.
- withProjectId(String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration.Builder
-
Specifies the project ID for the Cloud Bigtable instance.
- withProjectId(String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Specifies the project ID for the Cloud Bigtable instance.
- withProjectId(ValueProvider<String>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Specifies the project ID for the Cloud Bigtable instance.
- withProjectId(String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
-
Specifies the project ID for the Cloud Bigtable instance.
- withProjectId(ValueProvider<String>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
-
Specifies the project ID for the Cloud Bigtable instance.
- withRequest(ReadRowsRequest) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Specifies the
ReadRowsRequest
that will be used to filter the table. - withRequest(ValueProvider<ReadRowsRequest>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Specifies the
ReadRowsRequest
that will be used to filter the table. - withScan(Scan) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Specifies the
Scan
that will be used to filter the table. - withTableId(String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Specifies the table to connect to.
- withTableId(ValueProvider<String>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
-
Specifies the table to connect to.
- withTableId(String) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
-
Specifies the table to connect to.
- withTableId(ValueProvider<String>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
-
Specifies the table to connect to.
- writeToMultipleTables(CloudBigtableConfiguration) - Static method in class com.google.cloud.bigtable.beam.CloudBigtableIO
-
Creates a
PTransform
that can write either a bounded or unboundedPCollection
ofKV
of (String tableName, List ofMutation
s) to the specified table. - writeToTable(CloudBigtableTableConfiguration) - Static method in class com.google.cloud.bigtable.beam.CloudBigtableIO
-
Creates a
PTransform
that can write either a bounded or unboundedPCollection
ofMutation
s to a table specified via aCloudBigtableTableConfiguration
.