Index (Apache Beam + Cloud Bigtable Connector 1.5.0 API)

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<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 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 BigtableDataClient.sampleRowKeys(com.google.bigtable.repackaged.com.google.bigtable.v2.SampleRowKeysRequest).

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

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

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

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

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<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 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