Deprecated API

Contents

• Deprecated Interfaces
• Deprecated Classes
• Deprecated Enums
• Deprecated Fields
• Deprecated Methods
• Deprecated Constructors
• Deprecated Enum Constants

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.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.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.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.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.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.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.sdk.fn.data.BeamFnDataBufferingOutboundObserver.BEAM_FN_API_DATA_BUFFER_LIMIT Use DATA_BUFFER_SIZE_LIMIT instead.
org.apache.beam.sdk.fn.data.BeamFnDataBufferingOutboundObserver.BEAM_FN_API_DATA_BUFFER_SIZE_LIMIT Use DATA_BUFFER_SIZE_LIMIT instead.
org.apache.beam.sdk.fn.data.BeamFnDataBufferingOutboundObserver.BEAM_FN_API_DATA_BUFFER_TIME_LIMIT Use DATA_BUFFER_TIME_LIMIT_MS instead.
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.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.runners.fnexecution.GrpcFnServer.create(ServiceT, Endpoints.ApiServiceDescriptor) This create function is used for Dataflow migration purpose only.
org.apache.beam.sdk.io.mqtt.MqttIO.ConnectionConfiguration.create(String, String, String) This constructor will be removed in a future version of Beam, please use #create(String, String)} and MqttIO.ConnectionConfiguration.withClientId(String) instead.
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.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://issues.apache.org/jira/browse/BEAM-644 for details on a replacement.
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://issues.apache.org/jira/browse/BEAM-644 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.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.io.Source.getDefaultOutputCoder() Override Source.getOutputCoder() instead.
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.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.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.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.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.schemas.Schema.FieldType.map(Schema.FieldType, Schema.FieldType, boolean) Set the nullability on the valueType instead
org.apache.beam.sdk.metrics.MetricName.name() to be removed once Dataflow no longer requires this method.
org.apache.beam.sdk.metrics.MetricName.namespace() to be removed once Dataflow no longer requires this method.
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.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.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.sdk.extensions.gcp.options.GcpOptions.setZone(String) Use GcpOptions.setWorkerZone(java.lang.String) instead.
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://issues.apache.org/jira/browse/BEAM-644 for details on a replacement.
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.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.mongodb.MongoDbIO.Read.withFilter(String) Filtering manually is discouraged. Use with {@link FindQuery#withFilters(Bson)} as an argument to set up the projection.
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.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.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.mongodb.MongoDbIO.Read.withProjection(String...) Use with {@link FindQuery#withProjection(List)} as an argument to set up the projection.
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.gcp.bigquery.BigQueryIO.TypedRead.withReadOptions(ReadOptions.TableReadOptions) Use BigQueryIO.TypedRead.withSelectedFields(List) and BigQueryIO.TypedRead.withRowRestriction(String) instead.
org.apache.beam.sdk.transforms.View.AsMap.withSingletonValues() this method simply returns this AsMap unmodified
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.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.

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.