Index (Apache Beam + Cloud Bigtable Connector 1.0.0-pre3 API)

A B C D E F G I L P R S T 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
 

B

build() - Method in class com.google.cloud.bigtable.beam.CloudBigtableConfiguration.Builder
build() - Method in class com.google.cloud.bigtable.beam.CloudBigtableScanConfiguration.Builder
build() - Method in class com.google.cloud.bigtable.beam.CloudBigtableTableConfiguration.Builder
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

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(String, String, Map<String, 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
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.CloudBigtableWriteTransform<T> - Class in com.google.cloud.bigtable.beam
A PTransform that wraps around a DoFn that will write Mutations to Cloud Bigtable.
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(String, String, String, ReadRowsRequest, Map<String, 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
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(String, String, String, Map<String, 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
CloudBigtableWriteTransform(DoFn<T, Void>) - Constructor for class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableWriteTransform
 
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, 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
 
expand(PCollection<T>) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableWriteTransform
 

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

getBufferedMutator(DoFn<Mutation, Void>.StartBundleContext) - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.CloudBigtableSingleTableBufferedWriteFn
 
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
 
getDefaultOutputCoder() - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.Source
 
getDefaultOutputCoder() - Method in class com.google.cloud.bigtable.beam.CloudBigtableIO.SourceWithKeys
 
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.
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
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.CloudBigtableIO.CloudBigtableWriteTransform
 
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

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
 

W

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 W 


Monitor your resources on the go

Get the Google Cloud Console app to help you manage your projects.

Send feedback about...

Cloud Bigtable Documentation