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.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. |
Class and Description |
---|
org.apache.beam.sdk.transforms.ApproximateUnique
Consider using If For example, to estimate the number of distinct elements in a
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.coders.AvroCoder
Avro related classes are deprecated in module
beam-sdks-java-core and
will be eventually removed. Please, migrate to a new module
beam-sdks-java-extensions-avro by importing
org.apache.beam.sdk.extensions.avro.coders.AvroCoder instead of this one. |
org.apache.beam.sdk.coders.AvroGenericCoder
Avro related classes are deprecated in module
beam-sdks-java-core and
will be eventually removed. Please, migrate to a new module
beam-sdks-java-extensions-avro by importing
org.apache.beam.sdk.extensions.avro.coders.AvroGenericCoder instead of this one. |
org.apache.beam.sdk.io.AvroIO
Avro related classes are deprecated in module
beam-sdks-java-core and
will be eventually removed. Please, migrate to a new module
beam-sdks-java-extensions-avro by importing
org.apache.beam.sdk.extensions.avro.io.AvroIO instead of this one. |
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.schemas.io.payloads.AvroPayloadSerializerProvider
Avro related classes are deprecated in module
beam-sdks-java-core and
will be eventually removed. Please, migrate to a new module
beam-sdks-java-extensions-avro by importing
org.apache.beam.sdk.extensions.avro.schemas.io.payloads.AvroPayloadSerializerProvider
instead of this one. |
org.apache.beam.sdk.schemas.AvroRecordSchema
Avro related classes are deprecated in module
beam-sdks-java-core and
will be eventually removed. Please, migrate to a new module
beam-sdks-java-extensions-avro by importing
org.apache.beam.sdk.extensions.avro.schemas.AvroRecordSchema instead of this one. |
org.apache.beam.sdk.io.AvroSchemaIOProvider
Avro related classes are deprecated in module
beam-sdks-java-core and
will be eventually removed. Please, migrate to a new module
beam-sdks-java-extensions-avro by importing
org.apache.beam.sdk.extensions.avro.io.AvroSchemaIOProvider instead of this one. |
org.apache.beam.sdk.io.AvroSink
Avro related classes are deprecated in module
beam-sdks-java-core and
will be eventually removed. Please, migrate to a new module
beam-sdks-java-extensions-avro by importing
org.apache.beam.sdk.extensions.avro.io.AvroSink instead of this one. |
org.apache.beam.sdk.io.AvroSource
Avro related classes are deprecated in module
beam-sdks-java-core and
will be eventually removed. Please, migrate to a new module
beam-sdks-java-extensions-avro by importing
org.apache.beam.sdk.extensions.avro.io.AvroSource instead of this one. |
org.apache.beam.sdk.schemas.utils.AvroUtils
Avro related classes are deprecated in module
beam-sdks-java-core and
will be eventually removed. Please, migrate to a new module
beam-sdks-java-extensions-avro by importing
org.apache.beam.sdk.extensions.avro.schemas.utils.AvroUtils instead of this one. |
org.apache.beam.sdk.util.BitSetCoder
use
BitSetCoder instead |
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.DynamicAvroDestinations
Avro related classes are deprecated in module
beam-sdks-java-core and
will be eventually removed. Please, migrate to a new module
beam-sdks-java-extensions-avro by importing
org.apache.beam.sdk.extensions.avro.io.DynamicAvroDestinations instead of this one. |
org.apache.beam.sdk.values.PCollectionViews.IterableViewFn |
org.apache.beam.sdk.values.PCollectionViews.ListViewFn |
org.apache.beam.sdk.values.PCollectionViews.MapViewFn |
org.apache.beam.sdk.values.PCollectionViews.MultimapViewFn |
org.apache.beam.sdk.values.PCollectionViews.SingletonViewFn |
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.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 |
org.apache.beam.sdk.util.WindowedValue.ValueOnlyWindowedValueCoder
Use ParamWindowedValueCoder instead, it is a general purpose implementation of the
same concept but makes timestamp, windows and pane info configurable.
|
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 . |
Field and Description |
---|
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. |