Deprecated API

Contents

• Deprecated Interfaces
• Deprecated Classes
• Deprecated Methods
• Deprecated Enum Constants

Deprecated Interfaces

Interface and Description
org.apache.beam.sdk.testing.StreamingIT

Deprecated Classes

Class and Description
org.apache.beam.sdk.coders.Coder.Context
org.apache.beam.sdk.transforms.Combine.SimpleCombineFn
org.apache.beam.runners.dataflow.DataflowRunner.StreamingPCollectionViewWriterFn
org.apache.beam.sdk.values.PCollectionViews.IterableViewFn Beam views are migrating off of Iterable<WindowedValue<T>> as a primitive view type.
org.apache.beam.sdk.values.PCollectionViews.ListViewFn Beam views are migrating off of Iterable<WindowedValue<T>> as a primitive view type.
org.apache.beam.sdk.values.PCollectionViews.MapViewFn Beam views are migrating off of Iterable<WindowedValue<T>> as a primitive view type.
org.apache.beam.sdk.values.PCollectionViews.MultimapViewFn Beam views are migrating off of Iterable<WindowedValue<T>> as a primitive view type.
org.apache.beam.sdk.values.PCollectionViews.SingletonViewFn Beam views are migrating off of Iterable<WindowedValue<T>> as a primitive view type.
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

Deprecated Methods

Method and Description
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.AvroSource.createForSubrangeOfFile(String, long, long)
org.apache.beam.sdk.coders.Coder.decode(InputStream, Coder.Context)
org.apache.beam.sdk.coders.Coder.encode(T, OutputStream, Coder.Context)
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()
org.apache.beam.runners.dataflow.util.DoFnInfo.forFn(Serializable, WindowingStrategy<?, ?>, Iterable<PCollectionView<?>>, Coder<InputT>, long, Map<Long, TupleTag<?>>)
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.coders.CoderRegistry.getCoder(Class<? extends T>, Class<T>, Map<Type, ? extends Coder<?>>, TypeVariable<?>)
org.apache.beam.sdk.coders.CoderRegistry.getCoder(TypeDescriptor<OutputT>, TypeDescriptor<InputT>, Coder<InputT>)
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.runners.dataflow.util.DoFnInfo.getFn()
org.apache.beam.sdk.coders.CoderRegistry.getOutputCoder(SerializableFunction<InputT, OutputT>, Coder<InputT>)
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.transforms.View.CreatePCollectionView.getView()
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.testing.PAssert.PCollectionContentsAssert.hashCode() Object.hashCode() is not supported on PAssert objects.
org.apache.beam.sdk.transforms.Combine.SimpleCombineFn.of(SerializableFunction<Iterable<V>, V>)
org.apache.beam.sdk.transforms.DoFn.prepareForProcessing()
org.apache.beam.sdk.Pipeline.setCoderRegistry(CoderRegistry) this should never be used - every Pipeline has a registry throughout its lifetime.
org.apache.beam.sdk.io.FileSystems.setDefaultConfigInWorkers(PipelineOptions) to be removed.
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.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.transforms.View.AsMap.withSingletonValues() this method simply returns this AsMap unmodified

Deprecated Enum Constants

Enum Constant and Description
org.apache.beam.runners.dataflow.options.DataflowPipelineWorkerPoolOptions.AutoscalingAlgorithmType.BASIC