Deprecated API

Contents

• Classes
• Methods

Classes

Class	Description
org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.DynamicRead	this class may have breaking changes introduced, use with caution

Methods

Method	Description
org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.read()	Use BigQueryIO.read(SerializableFunction) or BigQueryIO.readTableRows() instead. BigQueryIO.readTableRows() does exactly the same as BigQueryIO.read(), however BigQueryIO.read(SerializableFunction) performs better.
org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.readDynamically(SerializableFunction<SchemaAndRecord, T>, Coder<T>)	this method may have breaking changes introduced, use with caution
org.apache.beam.sdk.io.gcp.bigquery.BigQueryIO.readDynamicallyTableRows()	this method may have breaking changes introduced, use with caution
org.apache.beam.sdk.io.gcp.bigquery.BigQueryUtils.convertGenericRecordToTableRow(GenericRecord, TableSchema)	use BigQueryUtils.convertGenericRecordToTableRow(GenericRecord)
org.apache.beam.sdk.io.gcp.bigquery.RowMutationInformation.getSequenceNumber()
org.apache.beam.sdk.io.gcp.bigquery.RowMutationInformation.of(RowMutationInformation.MutationType, long)
org.apache.beam.sdk.io.gcp.bigtable.BigtableConfig.withBigtableOptions(BigtableOptions)	please set the options directly in BigtableIO.
org.apache.beam.sdk.io.gcp.bigtable.BigtableConfig.withBigtableOptionsConfigurator(SerializableFunction<BigtableOptions.Builder, BigtableOptions.Builder>)	please set the options directly in BigtableIO.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Read.getBigtableOptions()	read options are configured directly on BigtableIO.read(). Use BigtableIO.Read.populateDisplayData(DisplayData.Builder) to view the current configurations.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Read.withBigtableOptions(BigtableOptions)	please set the configurations directly: BigtableIO.read().withProjectId(projectId).withInstanceId(instanceId).withTableId(tableId) and set credentials in PipelineOptions.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Read.withBigtableOptionsConfigurator(SerializableFunction<BigtableOptions.Builder, BigtableOptions.Builder>)	please set the configurations directly: BigtableIO.read().withProjectId(projectId).withInstanceId(instanceId).withTableId(tableId) and set credentials in PipelineOptions.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Write.getBigtableOptions()	write options are configured directly on BigtableIO.write(). Use BigtableIO.Write.populateDisplayData(DisplayData.Builder) to view the current configurations.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Write.withBigtableOptions(BigtableOptions)	please configure the write options directly: BigtableIO.write().withProjectId(projectId).withInstanceId(instanceId).withTableId(tableId) and set credentials in PipelineOptions.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Write.withBigtableOptionsConfigurator(SerializableFunction<BigtableOptions.Builder, BigtableOptions.Builder>)	please configure the write options directly: BigtableIO.write().withProjectId(projectId).withInstanceId(instanceId).withTableId(tableId) and set credentials in PipelineOptions.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Write.withThrottlingReportTargetMs(int)	This method has been deprecated in Beam 2.60.0. It does not have an effect.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Write.withThrottlingTargetMs(int)	This method has been deprecated in Beam 2.60.0. It does not have an effect.
org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubSubscription.asV1Beta1Path()	the v1beta1 API for Cloud Pub/Sub is deprecated.
org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubSubscription.asV1Beta2Path()	the v1beta2 API for Cloud Pub/Sub is deprecated.
org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubTopic.asV1Beta1Path()	the v1beta1 API for Cloud Pub/Sub is deprecated.
org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.PubsubTopic.asV1Beta2Path()	the v1beta2 API for Cloud Pub/Sub is deprecated.
org.apache.beam.sdk.io.gcp.pubsub.TestPubsub.checkIfAnySubscriptionExists(String, Duration)	Use TestPubsub.assertSubscriptionEventuallyCreated(java.lang.String, org.joda.time.Duration).
org.apache.beam.sdk.io.gcp.spanner.SpannerIO.ReadChangeStream.withTraceSampleProbability(Double)	This configuration has no effect, as tracing is not available.