Deprecated List (Apache Beam 2.44.0)

Deprecated Interfaces
Interface and Description
org.apache.beam.sdk.io.AvroIO.RecordFormatter Users can achieve the same by providing this transform in a `ParDo` before using write in AvroIO `AvroIO.write(Class)`.
org.apache.beam.sdk.io.aws2.kinesis.AWSClientsProvider Configure a custom `ClientBuilderFactory` using `AwsOptions.getClientBuilderFactory()` instead.
org.apache.beam.runners.dataflow.options.DataflowWorkerLoggingOptions This interface will no longer be the source of truth for worker logging configuration once jobs are executed using a dedicated SDK harness instead of user code being co-located alongside Dataflow worker code. Please set the option below and also the corresponding option within `SdkHarnessOptions` to ensure forward compatibility.
org.apache.beam.sdk.io.aws2.dynamodb.DynamoDbClientProvider Configure a custom `ClientBuilderFactory` using `AwsOptions.getClientBuilderFactory()` instead.
org.apache.beam.sdk.fn.data.InboundDataClient Migrate to `BeamFnDataInboundObserver2`.
org.apache.beam.sdk.io.aws2.sns.SnsClientProvider Configure a custom `ClientBuilderFactory` using `AwsOptions.getClientBuilderFactory()` instead.
org.apache.beam.sdk.io.aws2.sqs.SqsClientProvider Configure a custom `ClientBuilderFactory` using `AwsOptions.getClientBuilderFactory()` instead.
org.apache.beam.sdk.testing.StreamingIT tests which use unbounded PCollections should be in the category `UsesUnboundedPCollections`. Beyond that, it is up to the runner and test configuration to decide whether to run in streaming mode.

Deprecated Classes
Class and Description
org.apache.beam.sdk.transforms.ApproximateUnique Consider using `ApproximateCountDistinct` in the `zetasketch` extension module, which makes use of the `HllCount` implementation. If `ApproximateCountDistinct` does not meet your needs then you can directly use `HllCount`. Direct usage will also give you access to save intermediate aggregation result into a sketch for later processing. For example, to estimate the number of distinct elements in a `PCollection<String>`: `PCollection<String> input = ...; PCollection<Long> countDistinct = input.apply(HllCount.Init.forStrings().globally()).apply(HllCount.Extract.globally());` For more details about using `HllCount` and the `zetasketch` extension module, see https://s.apache.org/hll-in-beam#bookmark=id.v6chsij1ixo7.
org.apache.beam.sdk.io.AvroIO.ParseAll See `AvroIO.parseAllGenericRecords(SerializableFunction)` for details.
org.apache.beam.sdk.io.AvroIO.ReadAll See `AvroIO.readAll(Class)` for details.
org.apache.beam.sdk.io.aws2.coders.AwsCoders `SchemaCoders` for `AWS model classes` will be automatically inferred by means of `AwsSchemaProvider`.
org.apache.beam.sdk.io.aws2.dynamodb.BasicDynamoDbClientProvider Configure a custom `ClientBuilderFactory` using `AwsOptions.getClientBuilderFactory()` instead.
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer Migrate to `BeamFnDataGrpcMultiplexer2`.
org.apache.beam.sdk.fn.data.BeamFnDataInboundObserver Migrate to `BeamFnDataInboundObserver2`.
org.apache.beam.sdk.fn.data.BeamFnDataOutboundObserver Migrate to use `BeamFnDataOutboundAggregator` directly.
org.apache.beam.sdk.coders.Coder.Context To implement a coder, do not use any `Coder.Context`. Just implement only those abstract methods which do not accept a `Coder.Context` and leave the default implementations for methods accepting a `Coder.Context`.
org.apache.beam.sdk.transforms.Combine.SimpleCombineFn
org.apache.beam.sdk.transforms.DoFnTester Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.io.aws.dynamodb.DynamoDBIO Module `beam-sdks-java-io-amazon-web-services` is deprecated and will be eventually removed. Please migrate to `DynamoDBIO` in module `beam-sdks-java-io-amazon-web-services2`.
org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.RetryConfiguration Use `RetryConfiguration` instead to delegate retries to the AWS SDK.
org.apache.beam.sdk.io.kinesis.KinesisIO Module `beam-sdks-java-io-kinesis` is deprecated and will be eventually removed. Please migrate to `KinesisIO` in module `beam-sdks-java-io-amazon-web-services2`.
org.apache.beam.sdk.values.PCollectionViews.IterableViewFn See `PCollectionViews.IterableViewFn2`.
org.apache.beam.sdk.values.PCollectionViews.ListViewFn See `PCollectionViews.ListViewFn2`.
org.apache.beam.sdk.values.PCollectionViews.MapViewFn See `PCollectionViews.MapViewFn2`.
org.apache.beam.sdk.values.PCollectionViews.MultimapViewFn See `PCollectionViews.MultimapViewFn2`.
org.apache.beam.sdk.values.PCollectionViews.SingletonViewFn See `PCollectionViews.SingletonViewFn2`.
org.apache.beam.sdk.io.aws2.sns.PublishResponseCoders Schema based coder is inferred automatically.
org.apache.beam.sdk.transforms.Reshuffle this transform's intended side effects are not portable; it will likely be removed
org.apache.beam.sdk.transforms.windowing.ReshuffleTrigger The intended side effect of `Reshuffle` is not portable; it will likely be removed
org.apache.beam.runners.fnexecution.control.SingleEnvironmentInstanceJobBundleFactory replace with a `DefaultJobBundleFactory` when appropriate if the `EnvironmentFactory` is a `DockerEnvironmentFactory`, or create an `InProcessJobBundleFactory` and inline the creation of the environment if appropriate.
org.apache.beam.sdk.io.aws.sns.SnsIO Module `beam-sdks-java-io-amazon-web-services` is deprecated and will be eventually removed. Please migrate to `SnsIO` in module `beam-sdks-java-io-amazon-web-services2`.
org.apache.beam.sdk.io.aws2.sns.SnsIO.RetryConfiguration Use `RetryConfiguration` instead to delegate retries to the AWS SDK.
org.apache.beam.sdk.io.aws2.sns.SnsIO.WriteAsync Please use `SnsIO.write()` to avoid the risk of data loss.
org.apache.beam.sdk.io.aws.sqs.SqsIO Module `beam-sdks-java-io-amazon-web-services` is deprecated and will be eventually removed. Please migrate to `SqsIO` in module `beam-sdks-java-io-amazon-web-services2`.
org.apache.beam.sdk.io.TextIO.ReadAll See `TextIO.readAll()` for details.
org.apache.beam.sdk.transforms.Top.Largest use `Top.Natural` instead
org.apache.beam.sdk.transforms.Top.Smallest use `Top.Reversed` instead

Deprecated Enums
Enum and Description
org.apache.beam.sdk.io.CompressedSource.CompressionMode Use `Compression` instead
org.apache.beam.sdk.transforms.DoFnTester.CloningBehavior Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.io.FileBasedSink.CompressionType use `Compression`.
org.apache.beam.sdk.io.TextIO.CompressionType Use `Compression`.
org.apache.beam.sdk.io.TFRecordIO.CompressionType Use `Compression`.
org.apache.beam.sdk.io.xml.XmlIO.Read.CompressionType Use `Compression` instead.

Deprecated Fields
Field and Description
org.apache.beam.runners.dataflow.util.PropertyNames.RESTRICTION_CODER Uses the incorrect terminology. `PropertyNames.RESTRICTION_ENCODING`. Should be removed once non FnAPI SplittableDoFn expansion for Dataflow is removed.
org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.tokenNames Use `FieldSpecifierNotationParser.VOCABULARY` instead.
org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationLexer.tokenNames Use `FieldSpecifierNotationLexer.VOCABULARY` instead.
org.apache.beam.sdk.extensions.gcp.options.GcpOptions.WINDMILL_SERVICE_EXPERIMENT Use STREAMING_ENGINE_EXPERIMENT instead.

Deprecated Methods
Method and Description
org.apache.beam.sdk.schemas.Schema.FieldType.array(Schema.FieldType, boolean) Set the nullability on the elementType instead
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.PubsubTopic.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.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.transforms.DoFnTester.clearOutputElements() Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.clearOutputElements(TupleTag<T>) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.close() Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.testing.PAssert.IterableAssert.containsInAnyOrder() Prefer `PAssert.IterableAssert.empty()` to this method.
org.apache.beam.sdk.extensions.gcp.util.GcsUtil.create(GcsPath, String) Use `GcsUtil.create(GcsPath, CreateOptions)` instead.
org.apache.beam.sdk.extensions.gcp.util.GcsUtil.create(GcsPath, String, Integer) Use `GcsUtil.create(GcsPath, CreateOptions)` instead.
org.apache.beam.sdk.io.aws2.sns.SnsIO.RetryConfiguration.create(int, Duration) Use `RetryConfiguration` instead.
org.apache.beam.sdk.fn.server.GrpcFnServer.create(ServiceT, Endpoints.ApiServiceDescriptor) This create function is used for Dataflow migration purpose only.
org.apache.beam.sdk.io.AvroSource.createForSubrangeOfFile(String, long, long) Used by Dataflow worker
org.apache.beam.sdk.transforms.DoFnTester.createProcessContext(ValueInSingleWindow<InputT>) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.coders.Coder.decode(InputStream, Coder.Context) only implement and call `Coder.decode(InputStream)`
org.apache.beam.sdk.coders.Coder.encode(T, OutputStream, Coder.Context) only implement and call `Coder.encode(Object value, OutputStream)`
org.apache.beam.sdk.testing.PAssert.PCollectionContentsAssert.equals(Object) `Object.equals(Object)` is not supported on PAssert objects. If you meant to test object equality, use a variant of `PAssert.PCollectionContentsAssert.containsInAnyOrder(T...)` instead.
org.apache.beam.sdk.values.PValue.expand() A `PValue` always expands into itself. Calling `PValue.expand()` on a PValue is almost never appropriate.
org.apache.beam.sdk.transforms.DoFnTester.finishBundle() Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.fn.data.CloseableFnDataReceiver.flush() to be removed once splitting/checkpointing are available in SDKs and rewinding in readers.
org.apache.beam.sdk.schemas.Schema.FieldType.getAllMetadata() use schema options instead.
org.apache.beam.sdk.transforms.DoFn.getAllowedTimestampSkew() This method permits a `DoFn` to emit elements behind the watermark. These elements are considered late, and if behind the `allowed lateness` of a downstream `PCollection` may be silently dropped. See https://github.com/apache/beam/issues/18065 for details on a replacement.
org.apache.beam.sdk.transforms.WithTimestamps.getAllowedTimestampSkew() This method permits a to elements to be emitted behind the watermark. These elements are considered late, and if behind the `allowed lateness` of a downstream `PCollection` may be silently dropped. See https://github.com/apache/beam/issues/18065 for details on a replacement.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Read.getBigtableOptions() will be replaced by bigtable options configurator.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Write.getBigtableOptions() will be replaced by bigtable options configurator.
org.apache.beam.sdk.transforms.DoFnTester.getCloningBehavior() Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.io.aws.sns.AwsClientsProvider.getCloudWatchClient() SnsIO doesn't require a CloudWatch client
org.apache.beam.sdk.io.aws.dynamodb.AwsClientsProvider.getCloudWatchClient() DynamoDBIO doesn't require a CloudWatch client
org.apache.beam.sdk.coders.CoderRegistry.getCoder(Class<? extends T>, Class<T>, Map<Type, ? extends Coder<?>>, TypeVariable<?>) This method is to change in an unknown backwards incompatible way once support for this functionality is refined.
org.apache.beam.sdk.coders.CoderRegistry.getCoder(TypeDescriptor<OutputT>, TypeDescriptor<InputT>, Coder<InputT>) This method is to change in an unknown backwards incompatible way once support for this functionality is refined.
org.apache.beam.sdk.values.PCollectionView.getCoderInternal() this method will be removed entirely. The `PCollection` underlying a side input, including its `Coder`, is part of the side input's specification with a `ParDo` transform, which will obtain that information via a package-private channel.
org.apache.beam.sdk.transforms.PTransform.getDefaultOutputCoder() Instead, the PTransform should explicitly call `PCollection.setCoder(org.apache.beam.sdk.coders.Coder<T>)` on the returned PCollection.
org.apache.beam.sdk.io.Source.getDefaultOutputCoder() Override `Source.getOutputCoder()` instead.
org.apache.beam.sdk.transforms.PTransform.getDefaultOutputCoder(InputT) Instead, the PTransform should explicitly call `PCollection.setCoder(org.apache.beam.sdk.coders.Coder<T>)` on the returned PCollection.
org.apache.beam.sdk.transforms.PTransform.getDefaultOutputCoder(InputT, PCollection<T>) Instead, the PTransform should explicitly call `PCollection.setCoder(org.apache.beam.sdk.coders.Coder<T>)` on the returned PCollection.
org.apache.beam.sdk.extensions.gcp.options.GcsOptions.getExecutorService() use `ExecutorOptions.getScheduledExecutorService()` instead
org.apache.beam.runners.dataflow.util.MonitoringUtil.getJobMonitoringPageURL(String, String) this method defaults the region to "us-central1". Prefer using the overload with an explicit regionId parameter.
org.apache.beam.sdk.transforms.DoFnTester.getMainOutputTag() Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.schemas.Schema.FieldType.getMetadata(String) use schema options instead.
org.apache.beam.sdk.schemas.Schema.FieldType.getMetadataString(String) use schema options instead.
org.apache.beam.sdk.transforms.DoFnTester.getMutableOutput(TupleTag<T>) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.coders.CoderRegistry.getOutputCoder(SerializableFunction<InputT, OutputT>, Coder<InputT>) This method is to change in an unknown backwards incompatible way once support for this functionality is refined.
org.apache.beam.sdk.transforms.DoFnTester.getPipelineOptions() Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.runners.flink.FlinkPipelineOptions.getStateBackendFactory() Please use setStateBackend below.
org.apache.beam.sdk.values.PCollectionView.getTagInternal() this method will be removed entirely. The `PCollection` underlying a side input, is part of the side input's specification with a `ParDo` transform, which will obtain that information via a package-private channel.
org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationParser.getTokenNames()
org.apache.beam.sdk.schemas.parser.generated.FieldSpecifierNotationLexer.getTokenNames()
org.apache.beam.sdk.transforms.View.CreatePCollectionView.getView() This should not be used to obtain the output of any given application of this `PTransform`. That should be obtained by inspecting the `TransformHierarchy.Node` that contains this `View.CreatePCollectionView`, as this view may have been replaced within pipeline surgery.
org.apache.beam.sdk.values.PCollectionView.getViewFn() this method will be removed entirely. The `ViewFn` for a side input is an attribute of the side input's specification with a `ParDo` transform, which will obtain this specification via a package-private channel.
org.apache.beam.sdk.values.PCollectionView.getWindowingStrategyInternal() this method will be removed entirely. The `PCollection` underlying a side input, including its `WindowingStrategy`, is part of the side input's specification with a `ParDo` transform, which will obtain that information via a package-private channel.
org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions.getWorkerHarnessContainerImage() Use `DataflowPipelineWorkerPoolOptions.getSdkContainerImage()` instead.
org.apache.beam.sdk.extensions.gcp.options.GcpOptions.getZone() Use `GcpOptions.getWorkerZone()` instead.
org.apache.beam.sdk.testing.PAssert.PCollectionContentsAssert.hashCode() `Object.hashCode()` is not supported on PAssert objects.
org.apache.beam.sdk.transforms.windowing.WindowFn.isCompatible(WindowFn<?, ?>) please override verifyCompatibility to throw a useful error message; we will remove isCompatible at version 3.0.0
org.apache.beam.sdk.values.PCollectionViews.iterableViewUsingVoidKey(TupleTag<Materializations.MultimapView<Void, T>>, PCollection<KV<Void, T>>, PCollectionViews.TypeDescriptorSupplier<T>, WindowingStrategy<?, W>) See `PCollectionViews.iterableView(org.apache.beam.sdk.values.PCollection<T>, org.apache.beam.sdk.values.PCollectionViews.TypeDescriptorSupplier<T>, org.apache.beam.sdk.values.WindowingStrategy<?, W>)`.
org.apache.beam.sdk.expansion.ExternalTransformRegistrar.knownBuilders() Prefer implementing 'knownBuilderInstances'. This method will be removed in a future version of Beam.
org.apache.beam.sdk.values.PCollectionViews.listViewUsingVoidKey(PCollection<KV<Void, T>>, TupleTag<Materializations.MultimapView<Void, T>>, PCollectionViews.TypeDescriptorSupplier<T>, WindowingStrategy<?, W>) See `PCollectionViews.listView(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.Long, org.apache.beam.sdk.values.PCollectionViews.ValueOrMetadata<T, org.apache.beam.sdk.io.range.OffsetRange>>>, org.apache.beam.sdk.values.PCollectionViews.TypeDescriptorSupplier<T>, org.apache.beam.sdk.values.WindowingStrategy<?, W>)`.
org.apache.beam.sdk.values.PCollectionViews.listViewUsingVoidKey(TupleTag<Materializations.MultimapView<Void, T>>, PCollection<KV<Void, T>>, PCollectionViews.TypeDescriptorSupplier<T>, WindowingStrategy<?, W>) See `PCollectionViews.listView(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.Long, org.apache.beam.sdk.values.PCollectionViews.ValueOrMetadata<T, org.apache.beam.sdk.io.range.OffsetRange>>>, org.apache.beam.sdk.values.PCollectionViews.TypeDescriptorSupplier<T>, org.apache.beam.sdk.values.WindowingStrategy<?, W>)`.
org.apache.beam.sdk.schemas.Schema.FieldType.map(Schema.FieldType, Schema.FieldType, boolean) Set the nullability on the valueType instead
org.apache.beam.sdk.values.PCollectionViews.mapViewUsingVoidKey(TupleTag<Materializations.MultimapView<Void, KV<K, V>>>, PCollection<KV<Void, KV<K, V>>>, PCollectionViews.TypeDescriptorSupplier<K>, PCollectionViews.TypeDescriptorSupplier<V>, WindowingStrategy<?, W>) See `PCollectionViews.mapView(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<K, V>>, org.apache.beam.sdk.values.PCollectionViews.TypeDescriptorSupplier<K>, org.apache.beam.sdk.values.PCollectionViews.TypeDescriptorSupplier<V>, org.apache.beam.sdk.values.WindowingStrategy<?, W>)`.
org.apache.beam.sdk.values.PCollectionViews.multimapViewUsingVoidKey(TupleTag<Materializations.MultimapView<Void, KV<K, V>>>, PCollection<KV<Void, KV<K, V>>>, PCollectionViews.TypeDescriptorSupplier<K>, PCollectionViews.TypeDescriptorSupplier<V>, WindowingStrategy<?, W>) See `PCollectionViews.multimapView(org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<K, V>>, org.apache.beam.sdk.values.PCollectionViews.TypeDescriptorSupplier<K>, org.apache.beam.sdk.values.PCollectionViews.TypeDescriptorSupplier<V>, org.apache.beam.sdk.values.WindowingStrategy<?, W>)`.
org.apache.beam.sdk.transforms.DoFnTester.of(DoFn<InputT, OutputT>) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.io.AvroIO.parseAllGenericRecords(SerializableFunction<GenericRecord, T>) You can achieve The functionality of `AvroIO.parseAllGenericRecords(SerializableFunction)` using `FileIO` matching plus `AvroIO.parseFilesGenericRecords(SerializableFunction)` ()}. This is the preferred method to make composition explicit. `AvroIO.ParseAll` will not receive upgrades and will be removed in a future version of Beam.
org.apache.beam.sdk.transforms.DoFnTester.peekOutputElements() Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.peekOutputElements(TupleTag<T>) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.peekOutputElementsInWindow(BoundedWindow) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.peekOutputElementsInWindow(TupleTag<OutputT>, BoundedWindow) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.peekOutputElementsWithTimestamp() Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFn.prepareForProcessing() use `DoFn.Setup` or `DoFn.StartBundle` instead. This method will be removed in a future release.
org.apache.beam.sdk.transforms.DoFnTester.processBundle(InputT...) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.processBundle(Iterable<? extends InputT>) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.processElement(InputT) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.processTimestampedElement(TimestampedValue<InputT>) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.processWindowedElement(InputT, Instant, BoundedWindow) Use `TestPipeline` with the `DirectRunner`.
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.TextIO.readAll() You can achieve The functionality of `TextIO.readAll()` using `FileIO` matching plus `TextIO.readFiles()`. This is the preferred method to make composition explicit. `TextIO.ReadAll` will not receive upgrades and will be removed in a future version of Beam.
org.apache.beam.sdk.io.AvroIO.readAll(Class<T>) You can achieve The functionality of `AvroIO.readAll(java.lang.Class<T>)` using `FileIO` matching plus `AvroIO.readFiles(Class)`. This is the preferred method to make composition explicit. `AvroIO.ReadAll` will not receive upgrades and will be removed in a future version of Beam.
org.apache.beam.sdk.io.AvroIO.readAllGenericRecords(Schema) You can achieve The functionality of `AvroIO.readAllGenericRecords(Schema)` using `FileIO` matching plus `AvroIO.readFilesGenericRecords(Schema)`. This is the preferred method to make composition explicit. `AvroIO.ReadAll` will not receive upgrades and will be removed in a future version of Beam.
org.apache.beam.sdk.io.AvroIO.readAllGenericRecords(String) You can achieve The functionality of `AvroIO.readAllGenericRecords(String)` using `FileIO` matching plus `AvroIO.readFilesGenericRecords(String)`. This is the preferred method to make composition explicit. `AvroIO.ReadAll` will not receive upgrades and will be removed in a future version of Beam.
org.apache.beam.runners.fnexecution.data.FnDataService.send(LogicalEndpoint, Coder<T>) Migrate to use `BeamFnDataOutboundAggregator` directly for sending outbound data.
org.apache.beam.sdk.transforms.DoFnTester.setCloningBehavior(DoFnTester.CloningBehavior) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.Pipeline.setCoderRegistry(CoderRegistry) this should never be used - every `Pipeline` has a registry throughout its lifetime.
org.apache.beam.sdk.extensions.gcp.options.GcsOptions.setExecutorService(ExecutorService) use `ExecutorOptions.setScheduledExecutorService(java.util.concurrent.ScheduledExecutorService)` instead. If set, it may result in multiple ExecutorServices, and therefore thread pools, in the runtime.
org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.RetryConfiguration.Builder.setMaxDuration(Duration) Warning, max accumulative retry latency is silently ignored as it is not supported by the AWS SDK.
org.apache.beam.sdk.transforms.DoFnTester.setSideInput(PCollectionView<T>, BoundedWindow, T) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.setSideInputs(Map<PCollectionView<?>, Map<BoundedWindow, ?>>) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.runners.flink.FlinkPipelineOptions.setStateBackendFactory(Class<? extends FlinkStateBackendFactory>) Please use setStateBackend below.
org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions.setWorkerHarnessContainerImage(String) Use `DataflowPipelineWorkerPoolOptions.setSdkContainerImage(java.lang.String)` instead.
org.apache.beam.sdk.extensions.gcp.options.GcpOptions.setZone(String) Use `GcpOptions.setWorkerZone(java.lang.String)` instead.
org.apache.beam.sdk.values.PCollectionViews.singletonViewUsingVoidKey(TupleTag<Materializations.MultimapView<Void, T>>, PCollection<KV<Void, T>>, PCollectionViews.TypeDescriptorSupplier<T>, WindowingStrategy<?, W>, boolean, T, Coder<T>) See `PCollectionViews.singletonView(org.apache.beam.sdk.values.PCollection<T>, org.apache.beam.sdk.values.PCollectionViews.TypeDescriptorSupplier<T>, org.apache.beam.sdk.values.WindowingStrategy<?, W>, boolean, T, org.apache.beam.sdk.coders.Coder<T>)`.
org.apache.beam.sdk.io.AvroIO.sinkViaGenericRecords(Schema, AvroIO.RecordFormatter<ElementT>) RecordFormatter will be removed in future versions.
org.apache.beam.sdk.transforms.DoFnTester.startBundle() Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.takeOutputElements() Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.takeOutputElements(TupleTag<T>) Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.transforms.DoFnTester.takeOutputElementsWithTimestamp() Use `TestPipeline` with the `DirectRunner`.
org.apache.beam.sdk.io.AvroIO.Write.to(DynamicAvroDestinations<T, ?, T>) Use `FileIO.write()` or `FileIO.writeDynamic()` instead.
org.apache.beam.sdk.io.AvroIO.TypedWrite.to(DynamicAvroDestinations<UserT, NewDestinationT, OutputT>) Use `FileIO.write()` or `FileIO.writeDynamic()` instead.
org.apache.beam.sdk.io.TextIO.Write.to(FileBasedSink.DynamicDestinations<String, ?, String>) Use `FileIO.write()` or `FileIO.writeDynamic()` ()} with `TextIO.sink()` instead.
org.apache.beam.sdk.io.TextIO.TypedWrite.to(FileBasedSink.DynamicDestinations<UserT, NewDestinationT, String>) Use `FileIO.write()` or `FileIO.writeDynamic()` with `TextIO.sink()` instead.
org.apache.beam.sdk.io.TextIO.Write.to(SerializableFunction<String, DefaultFilenamePolicy.Params>, DefaultFilenamePolicy.Params) Use `FileIO.write()` or `FileIO.writeDynamic()` ()} with `TextIO.sink()` instead.
org.apache.beam.sdk.io.TextIO.TypedWrite.to(SerializableFunction<UserT, DefaultFilenamePolicy.Params>, DefaultFilenamePolicy.Params) Use `FileIO.write()` or `FileIO.writeDynamic()` with `TextIO.sink()` instead.
org.apache.beam.sdk.io.CountingSource.unbounded() use `GenerateSequence` instead
org.apache.beam.sdk.io.CountingSource.unboundedWithTimestampFn(SerializableFunction<Long, Instant>) use `GenerateSequence` and call `GenerateSequence.withTimestampFn(SerializableFunction)` instead
org.apache.beam.sdk.io.kafka.KafkaIO.Read.updateConsumerProperties(Map<String, Object>) as of version 2.13. Use `KafkaIO.Read.withConsumerConfigUpdates(Map)` instead
org.apache.beam.sdk.io.kafka.KafkaIO.WriteRecords.updateProducerProperties(Map<String, Object>) as of version 2.13. Use `KafkaIO.WriteRecords.withProducerConfigUpdates(Map)` instead.
org.apache.beam.sdk.io.kafka.KafkaIO.Write.updateProducerProperties(Map<String, Object>) as of version 2.13. Use `KafkaIO.Write.withProducerConfigUpdates(Map)` instead.
org.apache.beam.sdk.options.ValueProviders.updateSerializedOptions(String, Map<String, String>) Use `TestPipeline.newProvider(T)` for testing `ValueProvider` code.
org.apache.beam.sdk.io.CountingSource.upTo(long) use `GenerateSequence` instead
org.apache.beam.sdk.transforms.WithTimestamps.withAllowedTimestampSkew(Duration) This method permits a to elements to be emitted behind the watermark. These elements are considered late, and if behind the `allowed lateness` of a downstream `PCollection` may be silently dropped. See https://github.com/apache/beam/issues/18065 for details on a replacement.
org.apache.beam.sdk.io.aws2.kinesis.KinesisIO.Read.withAWSClientsProvider(AWSClientsProvider) Use `KinesisIO.Read.withClientConfiguration(ClientConfiguration)` instead. Alternatively you can configure a custom `ClientBuilderFactory` in `AwsOptions`.
org.apache.beam.sdk.io.aws2.kinesis.KinesisIO.Read.withAWSClientsProvider(AwsCredentialsProvider, Region) Use `KinesisIO.Read.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.kinesis.KinesisIO.Read.withAWSClientsProvider(AwsCredentialsProvider, Region, String) Use `KinesisIO.Read.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.kinesis.KinesisIO.Read.withAWSClientsProvider(String, String, Region) Use `KinesisIO.Read.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.kinesis.KinesisIO.Read.withAWSClientsProvider(String, String, Region, String) Use `KinesisIO.Read.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Read.withBigtableOptions(BigtableOptions.Builder) will be replaced by bigtable options configurator.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Write.withBigtableOptions(BigtableOptions.Builder) will be replaced by bigtable options configurator.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Read.withBigtableOptions(BigtableOptions) will be replaced by bigtable options configurator.
org.apache.beam.sdk.io.gcp.bigtable.BigtableIO.Write.withBigtableOptions(BigtableOptions) will be replaced by bigtable options configurator.
org.apache.beam.sdk.io.jdbc.JdbcIO.ReadAll.withCoder(Coder<OutputT>) `JdbcIO` is able to infer aprppriate coders from other parameters.
org.apache.beam.sdk.io.aws2.sns.SnsIO.Write.withCoder(Coder<PublishResponse>) Explicit usage of coders is deprecated. Inferred schemas provided by `AwsSchemaProvider` will be used instead.
org.apache.beam.sdk.io.jdbc.JdbcIO.Read.withCoder(Coder<T>) `JdbcIO` is able to infer aprppriate coders from other parameters.
org.apache.beam.sdk.io.jdbc.JdbcIO.ReadWithPartitions.withCoder(Coder<T>) `JdbcIO` is able to infer appropriate coders from other parameters.
org.apache.beam.sdk.io.TextIO.Read.withCompressionType(TextIO.CompressionType) Use `TextIO.Read.withCompression(org.apache.beam.sdk.io.Compression)`.
org.apache.beam.sdk.io.TextIO.ReadAll.withCompressionType(TextIO.CompressionType) Use `TextIO.ReadAll.withCompression(org.apache.beam.sdk.io.Compression)`.
org.apache.beam.sdk.io.TFRecordIO.Read.withCompressionType(TFRecordIO.CompressionType) Use `TFRecordIO.Read.withCompression(org.apache.beam.sdk.io.Compression)`.
org.apache.beam.sdk.io.TFRecordIO.Write.withCompressionType(TFRecordIO.CompressionType) use `TFRecordIO.Write.withCompression(org.apache.beam.sdk.io.Compression)`.
org.apache.beam.sdk.io.xml.XmlIO.Read.withCompressionType(XmlIO.Read.CompressionType) use `XmlIO.Read.withCompression(org.apache.beam.sdk.io.Compression)`.
org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.Read.withDynamoDbClientProvider(AwsCredentialsProvider, String) Use `DynamoDBIO.Read.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.Write.withDynamoDbClientProvider(AwsCredentialsProvider, String) Use `DynamoDBIO.Write.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.Read.withDynamoDbClientProvider(AwsCredentialsProvider, String, URI) Use `DynamoDBIO.Read.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.Write.withDynamoDbClientProvider(AwsCredentialsProvider, String, URI) Use `DynamoDBIO.Write.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.Read.withDynamoDbClientProvider(DynamoDbClientProvider) Use `DynamoDBIO.Read.withClientConfiguration(ClientConfiguration)` instead. Alternatively you can configure a custom `ClientBuilderFactory` in `AwsOptions`.
org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.Write.withDynamoDbClientProvider(DynamoDbClientProvider) Use `DynamoDBIO.Write.withClientConfiguration(ClientConfiguration)` instead. Alternatively you can configure a custom `ClientBuilderFactory` in `AwsOptions`.
org.apache.beam.sdk.io.TextIO.TypedWrite.withFormatFunction(SerializableFunction<UserT, String>) Use `FileIO.write()` or `FileIO.writeDynamic()` with `TextIO.sink()` instead.
org.apache.beam.sdk.io.aws2.sns.SnsIO.Write.withFullPublishResponse() Writes fail exceptionally in case of errors, there is no need to check headers.
org.apache.beam.sdk.io.aws2.sns.SnsIO.Write.withFullPublishResponseWithoutHeaders() Writes fail exceptionally in case of errors, there is no need to check headers.
org.apache.beam.sdk.io.FileIO.Write.withIgnoreWindowing() Avoid usage of this method: its effects are complex and it will be removed in future versions of Beam. Right now it exists for compatibility with `WriteFiles`.
org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.Write.withMaxParallelRequestsPerWindow(int) use `ElasticsearchIO.Write.withMaxParallelRequests(int)` instead
org.apache.beam.sdk.io.elasticsearch.ElasticsearchIO.BulkIO.withMaxParallelRequestsPerWindow(int) use `ElasticsearchIO.BulkIO.withMaxParallelRequests(int)` instead.
org.apache.beam.sdk.schemas.Schema.FieldType.withMetadata(Map<String, byte[]>) use schema options instead.
org.apache.beam.sdk.schemas.Schema.FieldType.withMetadata(String, byte[]) use schema options instead.
org.apache.beam.sdk.schemas.Schema.FieldType.withMetadata(String, String) use schema options instead.
org.apache.beam.sdk.io.aws2.sns.SnsIO.Write.withPublishRequestFn(SerializableFunction<T, PublishRequest>) Use `SnsIO.Write.withPublishRequestBuilder(SerializableFunction)` instead.
org.apache.beam.sdk.io.kafka.KafkaIO.Write.withPublishTimestampFunction(KafkaPublishTimestampFunction<KV<K, V>>) use `KafkaIO.WriteRecords` and `ProducerRecords` to set publish timestamp.
org.apache.beam.sdk.io.kafka.KafkaIO.WriteRecords.withPublishTimestampFunction(KafkaPublishTimestampFunction<ProducerRecord<K, V>>) use `ProducerRecords` to set publish timestamp.
org.apache.beam.sdk.io.aws2.dynamodb.DynamoDBIO.Write.withRetryConfiguration(DynamoDBIO.RetryConfiguration) Use `DynamoDBIO.Write.withClientConfiguration(ClientConfiguration)` with `RetryConfiguration` instead to delegate retries to the AWS SDK.
org.apache.beam.sdk.io.aws2.sns.SnsIO.Write.withRetryConfiguration(SnsIO.RetryConfiguration) Use `SnsIO.Write.withClientConfiguration(ClientConfiguration)` with `RetryConfiguration` instead to delegate retries to the AWS SDK.
org.apache.beam.sdk.transforms.View.AsMap.withSingletonValues() this method simply returns this AsMap unmodified
org.apache.beam.sdk.io.aws2.sns.SnsIO.Write.withSnsClientProvider(AwsCredentialsProvider, String) Use `SnsIO.Write.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.sns.SnsIO.Write.withSnsClientProvider(AwsCredentialsProvider, String, URI) Use `SnsIO.Write.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.sns.SnsIO.Write.withSnsClientProvider(SnsClientProvider) Use `SnsIO.Write.withClientConfiguration(ClientConfiguration)` instead. Alternatively you can configure a custom `ClientBuilderFactory` in `AwsOptions`.
org.apache.beam.sdk.io.aws2.sqs.SqsIO.Read.withSqsClientProvider(AwsCredentialsProvider, String) Use `SqsIO.Read.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.sqs.SqsIO.Write.withSqsClientProvider(AwsCredentialsProvider, String) Use `SqsIO.Write.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.sqs.SqsIO.Read.withSqsClientProvider(AwsCredentialsProvider, String, URI) Use `SqsIO.Read.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.sqs.SqsIO.Write.withSqsClientProvider(AwsCredentialsProvider, String, URI) Use `SqsIO.Write.withClientConfiguration(ClientConfiguration)` instead.
org.apache.beam.sdk.io.aws2.sqs.SqsIO.Read.withSqsClientProvider(SqsClientProvider) Use `SqsIO.Read.withClientConfiguration(ClientConfiguration)` instead. Alternatively you can configure a custom `ClientBuilderFactory` in `AwsOptions`.
org.apache.beam.sdk.io.aws2.sqs.SqsIO.Write.withSqsClientProvider(SqsClientProvider) Use `SqsIO.Write.withClientConfiguration(ClientConfiguration)` instead. Alternatively you can configure a custom `ClientBuilderFactory` in `AwsOptions`.
org.apache.beam.sdk.io.kafka.TimestampPolicyFactory.withTimestampFn(SerializableFunction<KafkaRecord<K, V>, Instant>) Use @`CustomTimestampPolicyWithLimitedDelay`.
org.apache.beam.sdk.io.kafka.KafkaIO.Read.withTimestampFn(SerializableFunction<KV<K, V>, Instant>) as of version 2.4. Use `KafkaIO.Read.withTimestampPolicyFactory(TimestampPolicyFactory)` instead.
org.apache.beam.sdk.io.kafka.KafkaIO.Read.withTimestampFn2(SerializableFunction<KafkaRecord<K, V>, Instant>) as of version 2.4. Use `KafkaIO.Read.withTimestampPolicyFactory(TimestampPolicyFactory)` instead.
org.apache.beam.sdk.io.gcp.spanner.SpannerIO.ReadChangeStream.withTraceSampleProbability(Double) This configuration has no effect, as tracing is not available.
org.apache.beam.sdk.io.kafka.KafkaIO.Read.withWatermarkFn(SerializableFunction<KV<K, V>, Instant>) as of version 2.4. Use `KafkaIO.Read.withTimestampPolicyFactory(TimestampPolicyFactory)` instead.
org.apache.beam.sdk.io.kafka.KafkaIO.Read.withWatermarkFn2(SerializableFunction<KafkaRecord<K, V>, Instant>) as of version 2.4. Use `KafkaIO.Read.withTimestampPolicyFactory(TimestampPolicyFactory)` instead.
org.apache.beam.sdk.io.aws2.sns.SnsIO.writeAsync() Please use `SnsIO.write()` to avoid the risk of data loss.

Deprecated Constructors
Constructor and Description

org.apache.beam.runners.fnexecution.data.GrpcDataService()
This constructor is for migrating Dataflow purpose only.

Deprecated Constructors
Constructor and Description
org.apache.beam.runners.fnexecution.data.GrpcDataService() This constructor is for migrating Dataflow purpose only.

Deprecated Enum Constants
Enum Constant and Description
org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions.AutoscalingAlgorithmType.BASIC use `DataflowPipelineWorkerPoolOptions.AutoscalingAlgorithmType.THROUGHPUT_BASED`.

Deprecated API

Contents