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 DoFns that require a Connection 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 PTransforms 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 unbounded PCollection of KV of (String tableName, List of Mutations) to the specified table.

CloudBigtableIO.CloudBigtableSingleTableBufferedWriteFn - Class in com.google.cloud.bigtable.beam

A DoFn that can write either a bounded or unbounded PCollection of Mutations to a table specified via a CloudBigtableTableConfiguration using the BufferedMutator.

CloudBigtableIO.Source - Class in com.google.cloud.bigtable.beam

A BoundedSource for a Cloud Bigtable Table, which is potentially filtered by a Scan.

CloudBigtableIO.SourceWithKeys - Class in com.google.cloud.bigtable.beam

A BoundedSource for a Cloud Bigtable Table with a start/stop key range, along with a potential filter via a Scan.

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.FinishBundleContext) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableMultiTableWriteFn

finishBundle(DoFn.FinishBundleContext) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableSingleTableBufferedWriteFn

Closes the BufferedMutator and Connection.

fromConfig(CloudBigtableTableConfiguration, Scan) - Static method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration

Converts a CloudBigtableTableConfiguration object to a CloudBigtableScanConfiguration that will perform the specified Scan 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.ProcessContext) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableMultiTableWriteFn

Uses the connection to create a new Table to write the Mutations to.

processElement(DoFn.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

Creates a BoundedSource for a Cloud Bigtable Table, which is potentially filtered by a Scan.

rethrowException(RetriesExhaustedWithDetailsException) - Static method in class com.google.cloud.bigtable.beam.AbstractCloudBigtableTableDoFn

S

setupBufferedMutator(DoFn.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 a BigtableOptions 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 HBase Configuration.

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(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, 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(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(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.

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(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 unbounded PCollection of KV of (String tableName, List of Mutations) 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 unbounded PCollection of Mutations to a table specified via a CloudBigtableTableConfiguration.

A B C D E F G I L P R S T V W