You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2023/05/09 22:58:56 UTC
[beam] branch master updated (ea2befd9832 -> 25f9a28596c)
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from ea2befd9832 Kafka write metrics and tests (#26575)
add 459e166abc4 Remove experimental annotation from Beam
new 25f9a28596c Merge pull request #26490: Remove experimental annotation from Beam
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
CHANGES.md | 6 +-
.../beam/model/fn_execution/v1/beam_fn_api.proto | 1 -
.../beam/model/pipeline/v1/beam_runner_api.proto | 3 -
.../org/apache/beam/model/pipeline/v1/schema.proto | 1 -
playground/infrastructure/api/v1/api_pb2_grpc.py | 1 -
.../runners/core/construction/CoderTranslator.java | 5 +-
.../beam/runners/core/construction/External.java | 3 -
.../beam/runners/core/metrics/MetricsLogger.java | 3 -
.../beam/runners/dataflow/DataflowRunner.java | 2 -
.../beam/runners/dataflow/DataflowRunnerHooks.java | 2 -
.../options/DataflowPipelineDebugOptions.java | 4 +-
.../dataflow/options/DataflowPipelineOptions.java | 2 -
.../options/DataflowPipelineWorkerPoolOptions.java | 13 +-
.../dataflow/options/DataflowProfilingOptions.java | 4 +-
.../util/RowCoderCloudObjectTranslator.java | 3 -
.../util/SchemaCoderCloudObjectTranslator.java | 3 -
.../dataflow/worker/ContextActivationObserver.java | 2 -
.../runners/samza/util/PipelineJsonRenderer.java | 3 -
.../SparkStructuredStreamingPipelineOptions.java | 2 -
.../SparkStructuredStreamingRunner.java | 2 -
.../beam/runners/spark/SparkPipelineOptions.java | 2 -
.../SparkPortableStreamingPipelineOptions.java | 2 -
.../main/java/org/apache/beam/sdk/Pipeline.java | 3 -
.../java/org/apache/beam/sdk/PipelineResult.java | 3 -
.../apache/beam/sdk/annotations/Experimental.java | 113 ------
.../java/org/apache/beam/sdk/coders/Coder.java | 6 -
.../beam/sdk/coders/CoderProviderRegistrar.java | 2 -
.../java/org/apache/beam/sdk/coders/RowCoder.java | 3 -
.../apache/beam/sdk/coders/RowCoderGenerator.java | 3 -
.../sdk/expansion/ExternalTransformRegistrar.java | 3 -
.../apache/beam/sdk/expansion/package-info.java | 3 -
.../apache/beam/sdk/harness/JvmInitializer.java | 2 -
.../main/java/org/apache/beam/sdk/io/AvroIO.java | 21 --
.../java/org/apache/beam/sdk/io/AvroSource.java | 6 +-
.../org/apache/beam/sdk/io/BlockBasedSource.java | 5 -
.../java/org/apache/beam/sdk/io/BoundedSource.java | 3 -
.../apache/beam/sdk/io/ClassLoaderFileSystem.java | 2 -
.../org/apache/beam/sdk/io/CompressedSource.java | 3 -
.../java/org/apache/beam/sdk/io/FileBasedSink.java | 21 --
.../main/java/org/apache/beam/sdk/io/FileIO.java | 3 -
.../java/org/apache/beam/sdk/io/FileSystem.java | 3 -
.../apache/beam/sdk/io/FileSystemRegistrar.java | 3 -
.../java/org/apache/beam/sdk/io/FileSystems.java | 3 -
.../org/apache/beam/sdk/io/GenerateSequence.java | 4 -
.../beam/sdk/io/LocalFileSystemRegistrar.java | 3 -
.../org/apache/beam/sdk/io/LocalResources.java | 3 -
.../beam/sdk/io/ReadAllViaFileBasedSource.java | 3 -
.../sdk/io/ReadAllViaFileBasedSourceTransform.java | 2 -
.../io/ReadAllViaFileBasedSourceWithFilename.java | 2 -
.../org/apache/beam/sdk/io/ShardingFunction.java | 3 -
.../main/java/org/apache/beam/sdk/io/Source.java | 3 -
.../java/org/apache/beam/sdk/io/TFRecordIO.java | 4 -
.../main/java/org/apache/beam/sdk/io/TextIO.java | 13 -
.../org/apache/beam/sdk/io/UnboundedSource.java | 3 -
.../java/org/apache/beam/sdk/io/WriteFiles.java | 3 -
.../org/apache/beam/sdk/io/fs/MatchResult.java | 3 -
.../org/apache/beam/sdk/io/fs/MetadataCoderV2.java | 3 -
.../java/org/apache/beam/sdk/io/fs/ResourceId.java | 3 -
.../apache/beam/sdk/io/fs/ResourceIdTester.java | 3 -
.../java/org/apache/beam/sdk/metrics/Counter.java | 4 -
.../org/apache/beam/sdk/metrics/Distribution.java | 4 -
.../beam/sdk/metrics/DistributionResult.java | 3 -
.../java/org/apache/beam/sdk/metrics/Gauge.java | 4 -
.../org/apache/beam/sdk/metrics/GaugeResult.java | 3 -
.../org/apache/beam/sdk/metrics/Histogram.java | 3 -
.../java/org/apache/beam/sdk/metrics/Metric.java | 3 -
.../org/apache/beam/sdk/metrics/MetricKey.java | 3 -
.../org/apache/beam/sdk/metrics/MetricName.java | 3 -
.../apache/beam/sdk/metrics/MetricNameFilter.java | 3 -
.../beam/sdk/metrics/MetricQueryResults.java | 3 -
.../org/apache/beam/sdk/metrics/MetricResult.java | 3 -
.../org/apache/beam/sdk/metrics/MetricResults.java | 3 -
.../java/org/apache/beam/sdk/metrics/Metrics.java | 3 -
.../apache/beam/sdk/metrics/MetricsContainer.java | 3 -
.../beam/sdk/metrics/MetricsEnvironment.java | 3 -
.../org/apache/beam/sdk/metrics/MetricsFilter.java | 3 -
.../apache/beam/sdk/metrics/MetricsOptions.java | 3 -
.../org/apache/beam/sdk/metrics/MetricsSink.java | 3 -
.../org/apache/beam/sdk/metrics/SinkMetrics.java | 4 -
.../org/apache/beam/sdk/metrics/SourceMetrics.java | 3 -
.../org/apache/beam/sdk/metrics/package-info.java | 3 -
.../beam/sdk/options/ExperimentalOptions.java | 4 +-
.../beam/sdk/options/FileStagingOptions.java | 2 -
.../options/ManualDockerEnvironmentOptions.java | 3 -
.../beam/sdk/options/PipelineOptionsFactory.java | 6 +-
.../beam/sdk/options/PortablePipelineOptions.java | 3 -
.../beam/sdk/options/RemoteEnvironmentOptions.java | 3 -
.../apache/beam/sdk/options/SdkHarnessOptions.java | 3 -
.../apache/beam/sdk/runners/PTransformMatcher.java | 3 -
.../sdk/runners/PTransformOverrideFactory.java | 3 -
.../apache/beam/sdk/schemas/AutoValueSchema.java | 3 -
.../java/org/apache/beam/sdk/schemas/Factory.java | 3 -
.../beam/sdk/schemas/FieldAccessDescriptor.java | 3 -
.../beam/sdk/schemas/FieldTypeDescriptors.java | 3 -
.../beam/sdk/schemas/FromRowUsingCreator.java | 3 -
.../sdk/schemas/GetterBasedSchemaProvider.java | 3 -
.../apache/beam/sdk/schemas/JavaBeanSchema.java | 4 -
.../apache/beam/sdk/schemas/JavaFieldSchema.java | 3 -
.../beam/sdk/schemas/NoSuchSchemaException.java | 4 -
.../beam/sdk/schemas/ProjectionConsumer.java | 2 -
.../beam/sdk/schemas/ProjectionProducer.java | 2 -
.../java/org/apache/beam/sdk/schemas/Schema.java | 3 -
.../org/apache/beam/sdk/schemas/SchemaCoder.java | 3 -
.../apache/beam/sdk/schemas/SchemaProvider.java | 3 -
.../beam/sdk/schemas/SchemaProviderRegistrar.java | 3 -
.../apache/beam/sdk/schemas/SchemaRegistry.java | 3 -
.../apache/beam/sdk/schemas/SchemaTranslation.java | 3 -
.../sdk/schemas/annotations/DefaultSchema.java | 3 -
.../sdk/schemas/annotations/SchemaCaseFormat.java | 3 -
.../beam/sdk/schemas/annotations/SchemaCreate.java | 3 -
.../annotations/SchemaFieldDescription.java | 3 -
.../sdk/schemas/annotations/SchemaFieldName.java | 3 -
.../sdk/schemas/annotations/SchemaFieldNumber.java | 3 -
.../beam/sdk/schemas/annotations/SchemaIgnore.java | 3 -
.../beam/sdk/schemas/io/DeadLetteredTransform.java | 3 -
.../org/apache/beam/sdk/schemas/io/Failure.java | 3 -
.../org/apache/beam/sdk/schemas/io/GenericDlq.java | 3 -
.../beam/sdk/schemas/io/GenericDlqProvider.java | 3 -
.../schemas/io/InvalidConfigurationException.java | 3 -
.../sdk/schemas/io/InvalidLocationException.java | 3 -
.../sdk/schemas/io/InvalidSchemaException.java | 3 -
.../org/apache/beam/sdk/schemas/io/Providers.java | 3 -
.../org/apache/beam/sdk/schemas/io/SchemaIO.java | 3 -
.../beam/sdk/schemas/io/SchemaIOProvider.java | 3 -
.../io/payloads/AvroPayloadSerializerProvider.java | 3 -
.../io/payloads/JsonPayloadSerializerProvider.java | 3 -
.../sdk/schemas/io/payloads/PayloadSerializer.java | 3 -
.../io/payloads/PayloadSerializerProvider.java | 3 -
.../schemas/io/payloads/PayloadSerializers.java | 3 -
.../sdk/schemas/logicaltypes/EnumerationType.java | 3 -
.../beam/sdk/schemas/logicaltypes/OneOfType.java | 3 -
.../logicaltypes/PassThroughLogicalType.java | 3 -
.../sdk/schemas/logicaltypes/PythonCallable.java | 2 -
.../sdk/schemas/logicaltypes/UuidLogicalType.java | 3 -
.../org/apache/beam/sdk/schemas/package-info.java | 3 -
.../beam/sdk/schemas/transforms/AddFields.java | 3 -
.../apache/beam/sdk/schemas/transforms/Cast.java | 3 -
.../beam/sdk/schemas/transforms/CoGroup.java | 3 -
.../beam/sdk/schemas/transforms/Convert.java | 3 -
.../beam/sdk/schemas/transforms/DropFields.java | 3 -
.../apache/beam/sdk/schemas/transforms/Filter.java | 3 -
.../apache/beam/sdk/schemas/transforms/Group.java | 3 -
.../apache/beam/sdk/schemas/transforms/Join.java | 3 -
.../beam/sdk/schemas/transforms/RenameFields.java | 3 -
.../sdk/schemas/transforms/SchemaAggregateFn.java | 3 -
.../sdk/schemas/transforms/SchemaTransform.java | 3 -
.../transforms/SchemaTransformProvider.java | 3 -
.../apache/beam/sdk/schemas/transforms/Select.java | 3 -
.../transforms/TypedSchemaTransformProvider.java | 3 -
.../beam/sdk/schemas/utils/AutoValueUtils.java | 3 -
.../beam/sdk/schemas/utils/AvroByteBuddyUtils.java | 3 -
.../apache/beam/sdk/schemas/utils/AvroUtils.java | 3 -
.../beam/sdk/schemas/utils/ConvertHelpers.java | 3 -
.../sdk/schemas/utils/FieldValueTypeSupplier.java | 3 -
.../beam/sdk/schemas/utils/JavaBeanUtils.java | 3 -
.../apache/beam/sdk/schemas/utils/JsonUtils.java | 3 -
.../apache/beam/sdk/schemas/utils/POJOUtils.java | 3 -
.../beam/sdk/schemas/utils/ReflectUtils.java | 3 -
.../beam/sdk/schemas/utils/SchemaZipFold.java | 3 -
.../beam/sdk/schemas/utils/SelectHelpers.java | 3 -
.../sdk/schemas/utils/StaticSchemaInference.java | 3 -
.../java/org/apache/beam/sdk/state/BagState.java | 3 -
.../org/apache/beam/sdk/state/CombiningState.java | 3 -
.../org/apache/beam/sdk/state/GroupingState.java | 3 -
.../java/org/apache/beam/sdk/state/MapState.java | 3 -
.../org/apache/beam/sdk/state/MultimapState.java | 3 -
.../apache/beam/sdk/state/OrderedListState.java | 3 -
.../org/apache/beam/sdk/state/ReadableState.java | 4 -
.../java/org/apache/beam/sdk/state/SetState.java | 4 -
.../main/java/org/apache/beam/sdk/state/State.java | 4 -
.../org/apache/beam/sdk/state/StateKeySpec.java | 4 -
.../java/org/apache/beam/sdk/state/StateSpec.java | 3 -
.../java/org/apache/beam/sdk/state/StateSpecs.java | 3 -
.../java/org/apache/beam/sdk/state/TimeDomain.java | 3 -
.../main/java/org/apache/beam/sdk/state/Timer.java | 3 -
.../java/org/apache/beam/sdk/state/TimerMap.java | 3 -
.../java/org/apache/beam/sdk/state/TimerSpec.java | 3 -
.../java/org/apache/beam/sdk/state/TimerSpecs.java | 3 -
.../java/org/apache/beam/sdk/state/Timers.java | 3 -
.../java/org/apache/beam/sdk/state/ValueState.java | 3 -
.../org/apache/beam/sdk/state/package-info.java | 3 -
.../org/apache/beam/sdk/testing/TestStream.java | 4 -
.../org/apache/beam/sdk/transforms/Contextful.java | 3 -
.../org/apache/beam/sdk/transforms/Create.java | 6 -
.../java/org/apache/beam/sdk/transforms/DoFn.java | 25 +-
.../beam/sdk/transforms/DoFnSchemaInformation.java | 3 -
.../sdk/transforms/ExternalTransformBuilder.java | 3 -
.../beam/sdk/transforms/FlatMapElements.java | 6 -
.../beam/sdk/transforms/GroupIntoBatches.java | 2 -
.../org/apache/beam/sdk/transforms/JsonToRow.java | 10 +-
.../apache/beam/sdk/transforms/MapElements.java | 6 -
.../beam/sdk/transforms/Materializations.java | 4 -
.../org/apache/beam/sdk/transforms/PTransform.java | 3 -
.../apache/beam/sdk/transforms/Requirements.java | 3 -
.../org/apache/beam/sdk/transforms/Reshuffle.java | 2 -
.../org/apache/beam/sdk/transforms/ToJson.java | 6 +-
.../java/org/apache/beam/sdk/transforms/Wait.java | 2 -
.../apache/beam/sdk/transforms/WithFailures.java | 3 -
.../beam/sdk/transforms/windowing/AfterAll.java | 3 -
.../beam/sdk/transforms/windowing/AfterEach.java | 3 -
.../beam/sdk/transforms/windowing/AfterFirst.java | 3 -
.../beam/sdk/transforms/windowing/AfterPane.java | 3 -
.../transforms/windowing/AfterProcessingTime.java | 3 -
.../sdk/transforms/windowing/AfterWatermark.java | 3 -
.../sdk/transforms/windowing/DefaultTrigger.java | 3 -
.../transforms/windowing/TimestampCombiner.java | 3 -
.../beam/sdk/transforms/windowing/Trigger.java | 3 -
.../beam/sdk/transforms/windowing/Window.java | 17 +-
.../sdk/transforms/windowing/WindowMappingFn.java | 7 +-
.../org/apache/beam/sdk/util/HistogramData.java | 5 -
.../java/org/apache/beam/sdk/util/RowJson.java | 3 -
.../org/apache/beam/sdk/values/PCollection.java | 8 -
.../apache/beam/sdk/values/PCollectionView.java | 3 -
.../apache/beam/sdk/values/PCollectionViews.java | 11 -
.../main/java/org/apache/beam/sdk/values/Row.java | 3 -
.../org/apache/beam/sdk/values/RowWithGetters.java | 3 -
.../org/apache/beam/sdk/values/RowWithStorage.java | 3 -
.../apache/beam/sdk/values/SchemaVerification.java | 2 -
.../apache/beam/sdk/values/WindowingStrategy.java | 13 +-
.../beam/sdk/extensions/arrow/ArrowConversion.java | 2 -
.../sdk/extensions/avro/coders/package-info.java | 3 -
.../apache/beam/sdk/extensions/avro/io/AvroIO.java | 21 --
.../beam/sdk/extensions/avro/io/AvroSource.java | 6 +-
.../beam/sdk/extensions/avro/io/package-info.java | 3 -
.../io/payloads/AvroPayloadSerializerProvider.java | 3 -
.../avro/schemas/io/payloads/package-info.java | 3 -
.../sdk/extensions/avro/schemas/package-info.java | 3 -
.../avro/schemas/utils/AvroByteBuddyUtils.java | 3 -
.../extensions/avro/schemas/utils/AvroUtils.java | 3 -
.../avro/schemas/utils/package-info.java | 3 -
.../core/annotation/stability/Experimental.java | 44 ---
.../core/annotation/stability/package-info.java | 19 -
.../core/translate/provider/CompositeProvider.java | 2 -
.../provider/GenericTranslatorProvider.java | 2 -
.../sdk/extensions/gcp/options/GcpOptions.java | 2 -
.../sdk/extensions/gcp/options/GcsOptions.java | 5 +-
.../gcp/storage/GcsFileSystemRegistrar.java | 3 -
.../sdk/extensions/gcp/storage/package-info.java | 4 -
.../beam/sdk/extensions/jackson/AsJsons.java | 5 -
.../beam/sdk/extensions/jackson/ParseJsons.java | 5 -
.../apache/beam/sdk/extensions/kryo/KryoCoder.java | 2 -
.../sdk/extensions/kryo/KryoCoderProvider.java | 2 -
.../beam/sdk/extensions/kryo/KryoOptions.java | 2 -
.../beam/sdk/extensions/kryo/KryoRegistrar.java | 2 -
.../beam/sdk/extensions/ml/AnnotateImages.java | 2 -
.../beam/sdk/extensions/ml/AnnotateText.java | 2 -
.../ml/AnnotateVideoBytesWithContextFn.java | 2 -
.../beam/sdk/extensions/ml/AnnotateVideoFn.java | 2 -
.../extensions/ml/AnnotateVideoFromBytesFn.java | 2 -
.../sdk/extensions/ml/AnnotateVideoFromURIFn.java | 2 -
.../ml/AnnotateVideoURIWithContextFn.java | 2 -
.../beam/sdk/extensions/ml/BatchRequestForDLP.java | 3 +-
.../apache/beam/sdk/extensions/ml/CloudVision.java | 2 -
.../beam/sdk/extensions/ml/DLPDeidentifyText.java | 2 -
.../beam/sdk/extensions/ml/DLPInspectText.java | 2 -
.../beam/sdk/extensions/ml/DLPReidentifyText.java | 2 -
.../beam/sdk/extensions/ml/VideoIntelligence.java | 6 -
.../beam/sdk/extensions/ml/package-info.java | 3 -
.../extensions/protobuf/ProtoByteBuddyUtils.java | 6 -
.../protobuf/ProtoDynamicMessageSchema.java | 2 -
.../extensions/protobuf/ProtoMessageSchema.java | 3 -
.../protobuf/ProtoPayloadSerializerProvider.java | 3 -
.../protobuf/ProtoSchemaLogicalTypes.java | 3 -
.../python/transforms/DataframeTransform.java | 2 +-
.../extensions/python/transforms/PythonMap.java | 2 +-
.../extensions/python/transforms/RunInference.java | 2 +-
.../beam/sdk/extensions/sbe/IrFieldGenerator.java | 3 -
.../beam/sdk/extensions/sbe/PrimitiveSbeField.java | 3 -
.../apache/beam/sdk/extensions/sbe/SbeField.java | 3 -
.../beam/sdk/extensions/sbe/SbeLogicalTypes.java | 3 -
.../apache/beam/sdk/extensions/sbe/SbeSchema.java | 3 -
.../beam/sdk/extensions/sbe/SerializableIr.java | 3 -
.../beam/sdk/extensions/sbe/package-info.java | 4 -
.../ExternalSchemaIOTransformRegistrar.java | 2 -
.../extensions/sketching/ApproximateDistinct.java | 6 -
.../extensions/sketching/SketchFrequencies.java | 5 -
.../sdk/extensions/sketching/TDigestQuantiles.java | 5 -
.../sdk/extensions/sketching/package-info.java | 3 -
.../sdk/extensions/sql/example/package-info.java | 3 -
.../sql/meta/provider/datacatalog/SchemaUtils.java | 3 -
.../meta/provider/datacatalog/package-info.java | 3 -
.../SqlTransformSchemaTransformProvider.java | 2 -
.../sql/meta/provider/hcatalog/HCatalogTable.java | 2 -
.../sql/meta/provider/hcatalog/package-info.java | 3 -
sdks/java/extensions/sql/jdbc/build.gradle | 1 -
.../beam/sdk/extensions/sql/jdbc/package-info.java | 3 -
.../apache/beam/sdk/extensions/sql/BeamSqlCli.java | 2 -
.../sdk/extensions/sql/BeamSqlSeekableTable.java | 2 -
.../apache/beam/sdk/extensions/sql/BeamSqlUdf.java | 2 -
.../beam/sdk/extensions/sql/SqlTransform.java | 15 +-
.../sdk/extensions/sql/TypedCombineFnDelegate.java | 2 -
.../beam/sdk/extensions/sql/impl/BeamSqlEnv.java | 2 -
.../extensions/sql/impl/BeamTableStatistics.java | 2 -
.../beam/sdk/extensions/sql/impl/UdafImpl.java | 2 -
.../sdk/extensions/sql/impl/udaf/StringAgg.java | 2 -
.../sql/meta/provider/FullNameTableProvider.java | 2 -
.../provider/SchemaIOTableProviderWrapper.java | 2 -
.../sql/meta/provider/UdfUdafProvider.java | 2 -
.../sql/meta/provider/bigquery/BigQueryTable.java | 2 -
.../sql/meta/provider/bigtable/BigtableTable.java | 2 -
.../provider/bigtable/BigtableTableProvider.java | 2 -
.../sql/meta/provider/mongodb/MongoDbTable.java | 2 -
.../meta/provider/pubsub/PubsubTableProvider.java | 2 -
.../sql/meta/provider/test/TestBoundedTable.java | 2 -
.../sql/meta/provider/test/TestTable.java | 2 -
.../sql/meta/provider/test/TestTableUtils.java | 2 -
.../sql/meta/provider/test/TestUnboundedTable.java | 2 -
.../beam/sdk/extensions/sql/udf/AggregateFn.java | 3 -
.../beam/sdk/extensions/sql/udf/ScalarFn.java | 3 -
.../beam/sdk/extensions/sql/udf/package-info.java | 2 +-
.../sdk/extensions/sql/zetasql/package-info.java | 3 -
.../sql/zetasql/translation/impl/package-info.java | 3 -
.../sql/zetasql/translation/package-info.java | 3 -
.../sql/zetasql/unnest/package-info.java | 3 -
.../zetasketch/ApproximateCountDistinct.java | 2 -
.../beam/sdk/extensions/zetasketch/HllCount.java | 2 -
.../sdk/extensions/zetasketch/package-info.java | 3 -
.../java/org/apache/beam/fn/harness/Cache.java | 3 -
.../beam/sdk/io/aws/dynamodb/DynamoDBIO.java | 3 -
.../beam/sdk/io/aws/dynamodb/package-info.java | 4 -
.../beam/sdk/io/aws/options/package-info.java | 4 -
.../aws/s3/DefaultS3FileSystemSchemeRegistrar.java | 3 -
.../sdk/io/aws/s3/S3FileSystemConfiguration.java | 3 -
.../beam/sdk/io/aws/s3/S3FileSystemRegistrar.java | 3 -
.../sdk/io/aws/s3/S3FileSystemSchemeRegistrar.java | 3 -
.../apache/beam/sdk/io/aws/s3/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/aws/sns/SnsIO.java | 3 -
.../apache/beam/sdk/io/aws/sns/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/aws/sqs/SqsIO.java | 3 -
.../apache/beam/sdk/io/aws/sqs/package-info.java | 4 -
.../apache/beam/sdk/io/aws2/common/ObjectPool.java | 2 -
.../beam/sdk/io/aws2/common/package-info.java | 4 -
.../beam/sdk/io/aws2/dynamodb/DynamoDBIO.java | 3 -
.../beam/sdk/io/aws2/dynamodb/package-info.java | 4 -
.../apache/beam/sdk/io/aws2/kinesis/KinesisIO.java | 3 -
.../beam/sdk/io/aws2/kinesis/KinesisIOOptions.java | 3 -
.../beam/sdk/io/aws2/kinesis/package-info.java | 4 -
.../apache/beam/sdk/io/aws2/options/AwsModule.java | 3 -
.../beam/sdk/io/aws2/options/AwsOptions.java | 3 -
.../beam/sdk/io/aws2/options/package-info.java | 4 -
.../s3/DefaultS3FileSystemSchemeRegistrar.java | 3 -
.../sdk/io/aws2/s3/S3FileSystemConfiguration.java | 3 -
.../beam/sdk/io/aws2/s3/S3FileSystemRegistrar.java | 3 -
.../io/aws2/s3/S3FileSystemSchemeRegistrar.java | 3 -
.../apache/beam/sdk/io/aws2/s3/package-info.java | 4 -
.../beam/sdk/io/aws2/schemas/package-info.java | 4 -
.../org/apache/beam/sdk/io/aws2/sns/SnsIO.java | 3 -
.../apache/beam/sdk/io/aws2/sns/package-info.java | 4 -
.../org/apache/beam/sdk/io/aws2/sqs/SqsIO.java | 3 -
.../apache/beam/sdk/io/aws2/sqs/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/amqp/AmqpIO.java | 3 -
.../org/apache/beam/sdk/io/amqp/package-info.java | 4 -
.../AzureBlobStoreFileSystemRegistrar.java | 2 -
.../beam/sdk/io/azure/blobstore/package-info.java | 4 -
.../sdk/io/azure/options/BlobstoreOptions.java | 3 -
.../beam/sdk/io/azure/options/package-info.java | 4 -
.../apache/beam/sdk/io/cassandra/CassandraIO.java | 3 -
.../org/apache/beam/sdk/io/cassandra/Mapper.java | 3 -
.../apache/beam/sdk/io/cassandra/RingRange.java | 3 -
.../apache/beam/sdk/io/cassandra/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/cdap/CdapIO.java | 5 -
.../beam/sdk/io/cdap/context/package-info.java | 4 -
.../org/apache/beam/sdk/io/cdap/package-info.java | 4 -
.../beam/sdk/io/clickhouse/ClickHouseIO.java | 3 -
.../beam/sdk/io/clickhouse/ClickHouseWriter.java | 3 -
.../apache/beam/sdk/io/clickhouse/TableSchema.java | 3 -
.../beam/sdk/io/clickhouse/package-info.java | 4 -
.../beam/sdk/io/contextualtextio/package-info.java | 3 -
.../org/apache/beam/io/debezium/DebeziumIO.java | 3 -
.../io/debezium/DebeziumTransformRegistrar.java | 2 -
.../org/apache/beam/io/debezium/package-info.java | 4 -
.../beam/sdk/io/elasticsearch/ElasticsearchIO.java | 3 -
.../beam/sdk/io/elasticsearch/package-info.java | 4 -
.../BigQueryExportReadSchemaTransformProvider.java | 3 -
...QueryFileLoadsWriteSchemaTransformProvider.java | 3 -
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 22 +-
.../beam/sdk/io/gcp/bigquery/BigQueryOptions.java | 3 -
.../io/gcp/bigquery/BigQueryQuerySourceDef.java | 3 -
.../io/gcp/bigquery/BigQuerySchemaIOProvider.java | 4 -
.../sdk/io/gcp/bigquery/BigQuerySourceDef.java | 3 -
.../io/gcp/bigquery/BigQueryTableSourceDef.java | 3 -
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 10 -
.../beam/sdk/io/gcp/bigquery/TestBigQuery.java | 7 -
.../BigQueryDirectReadSchemaTransformProvider.java | 3 -
...ueryStorageWriteApiSchemaTransformProvider.java | 3 -
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 4 -
.../changestreams/action/package-info.java | 3 -
.../bigtable/changestreams/dao/package-info.java | 3 -
.../bigtable/changestreams/dofn/package-info.java | 3 -
.../changestreams/encoder/package-info.java | 2 -
.../changestreams/estimator/package-info.java | 2 -
.../bigtable/changestreams/model/package-info.java | 3 -
.../gcp/bigtable/changestreams/package-info.java | 3 -
.../changestreams/reconciler/package-info.java | 2 -
.../changestreams/restriction/package-info.java | 3 -
.../beam/sdk/io/gcp/bigtable/package-info.java | 4 -
.../beam/sdk/io/gcp/datastore/package-info.java | 4 -
.../beam/sdk/io/gcp/firestore/FirestoreIO.java | 4 -
.../beam/sdk/io/gcp/firestore/FirestoreV1.java | 4 -
.../beam/sdk/io/gcp/firestore/package-info.java | 4 -
.../beam/sdk/io/gcp/healthcare/package-info.java | 4 -
.../beam/sdk/io/gcp/pubsub/ExternalRead.java | 2 -
.../beam/sdk/io/gcp/pubsub/ExternalWrite.java | 2 -
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 8 -
.../beam/sdk/io/gcp/pubsub/PubsubMessageToRow.java | 2 -
.../PubsubReadSchemaTransformConfiguration.java | 2 -
.../pubsub/PubsubReadSchemaTransformProvider.java | 3 -
.../beam/sdk/io/gcp/pubsub/PubsubRowToMessage.java | 2 -
.../PubsubSchemaTransformMessageToRowFactory.java | 3 -
.../beam/sdk/io/gcp/pubsub/PubsubTestClient.java | 2 -
.../PubsubWriteSchemaTransformConfiguration.java | 2 -
.../pubsub/PubsubWriteSchemaTransformProvider.java | 3 -
.../beam/sdk/io/gcp/pubsublite/PubsubLiteIO.java | 2 -
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 9 +-
.../io/gcp/spanner/SpannerTransformRegistrar.java | 10 -
.../spanner/changestreams/action/package-info.java | 3 -
.../spanner/changestreams/dao/package-info.java | 3 -
.../spanner/changestreams/dofn/package-info.java | 3 -
.../changestreams/encoder/package-info.java | 3 -
.../changestreams/estimator/package-info.java | 3 -
.../spanner/changestreams/mapper/package-info.java | 3 -
.../spanner/changestreams/model/package-info.java | 3 -
.../io/gcp/spanner/changestreams/package-info.java | 4 -
.../changestreams/restriction/package-info.java | 3 -
.../beam/sdk/io/gcp/spanner/package-info.java | 4 -
.../beam/sdk/io/gcp/testing/BigqueryMatcher.java | 2 -
.../apache/beam/sdk/io/hadoop/package-info.java | 4 -
.../beam/sdk/io/hdfs/HadoopFileSystemOptions.java | 3 -
.../sdk/io/hdfs/HadoopFileSystemRegistrar.java | 3 -
.../org/apache/beam/sdk/io/hdfs/package-info.java | 4 -
.../beam/sdk/io/hadoop/format/HadoopFormatIO.java | 3 -
.../beam/sdk/io/hadoop/format/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/hbase/HBaseIO.java | 9 -
.../org/apache/beam/sdk/io/hbase/package-info.java | 4 -
.../org/apache/beam/sdk/io/hcatalog/HCatToRow.java | 3 -
.../beam/sdk/io/hcatalog/HCatalogBeamSchema.java | 3 -
.../apache/beam/sdk/io/hcatalog/HCatalogIO.java | 3 -
.../apache/beam/sdk/io/hcatalog/SchemaUtils.java | 3 -
.../apache/beam/sdk/io/hcatalog/package-info.java | 4 -
.../apache/beam/sdk/io/influxdb/InfluxDbIO.java | 3 -
.../org/apache/beam/sdk/io/jdbc/LogicalTypes.java | 3 -
.../org/apache/beam/sdk/io/jdbc/SchemaUtil.java | 3 -
.../org/apache/beam/sdk/io/jdbc/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 3 -
.../org/apache/beam/sdk/io/jms/package-info.java | 4 -
...onfluentSchemaRegistryDeserializerProvider.java | 3 -
.../beam/sdk/io/kafka/DeserializerProvider.java | 3 -
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 10 -
.../KafkaReadSchemaTransformConfiguration.java | 2 -
.../sdk/io/kafka/WatchForKafkaTopicPartitions.java | 2 -
.../org/apache/beam/sdk/io/kafka/package-info.java | 4 -
.../kafka/serialization/InstantDeserializer.java | 3 -
.../io/kafka/serialization/InstantSerializer.java | 3 -
.../sdk/io/kafka/serialization/package-info.java | 4 -
.../org/apache/beam/sdk/io/kinesis/KinesisIO.java | 3 -
.../sdk/io/kinesis/KinesisTransformRegistrar.java | 3 -
.../apache/beam/sdk/io/kinesis/package-info.java | 4 -
.../beam/sdk/io/kinesis/serde/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/kudu/KuduIO.java | 7 +-
.../org/apache/beam/sdk/io/kudu/package-info.java | 4 -
.../beam/sdk/io/mongodb/AggregationQuery.java | 3 -
.../org/apache/beam/sdk/io/mongodb/FindQuery.java | 3 -
.../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 3 -
.../org/apache/beam/sdk/io/mongodb/MongoDbIO.java | 3 -
.../beam/sdk/io/mongodb/UpdateConfiguration.java | 3 -
.../apache/beam/sdk/io/mongodb/UpdateField.java | 3 -
.../apache/beam/sdk/io/mongodb/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/mqtt/MqttIO.java | 3 -
.../org/apache/beam/sdk/io/mqtt/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/neo4j/Neo4jIO.java | 2 -
.../org/apache/beam/sdk/io/neo4j/package-info.java | 4 -
.../org/apache/beam/sdk/io/parquet/ParquetIO.java | 9 -
.../apache/beam/sdk/io/parquet/package-info.java | 4 -
.../apache/beam/sdk/io/rabbitmq/RabbitMqIO.java | 3 -
.../apache/beam/sdk/io/rabbitmq/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/redis/RedisIO.java | 3 -
.../org/apache/beam/sdk/io/redis/package-info.java | 4 -
.../beam/sdk/io/singlestore/package-info.java | 4 -
.../apache/beam/sdk/io/snowflake/SnowflakeIO.java | 2 -
.../io/snowflake/crosslanguage/ReadBuilder.java | 3 -
.../crosslanguage/SnowflakeTransformRegistrar.java | 3 -
.../io/snowflake/crosslanguage/WriteBuilder.java | 3 -
.../io/snowflake/crosslanguage/package-info.java | 3 -
.../java/org/apache/beam/sdk/io/solr/SolrIO.java | 3 -
.../org/apache/beam/sdk/io/solr/package-info.java | 4 -
.../beam/sdk/io/sparkreceiver/SparkReceiverIO.java | 3 -
.../beam/sdk/io/sparkreceiver/package-info.java | 4 -
.../org/apache/beam/sdk/io/splunk/SplunkIO.java | 3 -
.../apache/beam/sdk/io/splunk/package-info.java | 4 -
.../sdk/io/synthetic/SyntheticBoundedSource.java | 3 -
.../sdk/io/synthetic/SyntheticUnboundedSource.java | 3 -
.../beam/sdk/io/synthetic/delay/package-info.java | 4 -
.../apache/beam/sdk/io/synthetic/package-info.java | 4 -
.../org/apache/beam/sdk/io/thrift/ThriftIO.java | 6 -
.../io/thrift/ThriftPayloadSerializerProvider.java | 3 -
.../apache/beam/sdk/io/thrift/ThriftSchema.java | 2 -
.../apache/beam/sdk/io/thrift/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/tika/TikaIO.java | 3 -
.../org/apache/beam/sdk/io/tika/package-info.java | 4 -
.../org/apache/beam/sdk/io/xml/package-info.java | 4 -
.../coders/proto2_coder_test_messages_pb2.py | 35 +-
sdks/python/apache_beam/internal/metrics/metric.py | 5 +-
sdks/python/apache_beam/io/fileio.py | 3 -
sdks/python/apache_beam/io/gcp/bigquery.py | 2 -
.../apache_beam/io/gcp/experimental/spannerio.py | 3 -
.../clients/bigquery/bigquery_v2_client.py | 260 +++++++------
.../clients/bigquery/bigquery_v2_messages.py | 223 +++++------
.../internal/clients/storage/storage_v1_client.py | 410 +++++++++++++--------
.../clients/storage/storage_v1_messages.py | 78 ++--
sdks/python/apache_beam/io/mongodbio.py | 3 -
sdks/python/apache_beam/metrics/metric.py | 2 -
sdks/python/apache_beam/ml/gcp/cloud_dlp.py | 3 -
.../apache_beam/ml/inference/pytorch_inference.py | 2 -
.../apache_beam/ml/inference/sklearn_inference.py | 2 -
.../apache_beam/ml/inference/tensorrt_inference.py | 2 -
.../python/apache_beam/options/pipeline_options.py | 2 -
.../clients/cloudbuild/cloudbuild_v1_messages.py | 2 +-
.../clients/dataflow/dataflow_v1b3_client.py | 375 ++++++++++---------
.../clients/dataflow/dataflow_v1b3_messages.py | 395 ++++++++++----------
.../apache_beam/runners/direct/direct_runner.py | 2 -
.../apache_beam/runners/worker/bundle_processor.py | 1 -
.../apache_beam/runners/worker/data_plane.py | 2 -
.../apache_beam/runners/worker/log_handler.py | 2 -
sdks/python/apache_beam/runners/worker/logger.py | 2 -
.../apache_beam/runners/worker/opcounters.py | 2 -
.../apache_beam/runners/worker/operation_specs.py | 2 -
.../apache_beam/runners/worker/sdk_worker_main.py | 2 -
.../apache_beam/runners/worker/sideinputs.py | 2 -
.../apache_beam/runners/worker/statesampler.py | 2 -
.../runners/worker/statesampler_slow.py | 2 -
sdks/python/apache_beam/transforms/core.py | 4 -
sdks/python/apache_beam/transforms/external.py | 7 +-
sdks/python/apache_beam/transforms/ptransform.py | 3 -
sdks/python/apache_beam/transforms/trigger.py | 12 +-
sdks/python/apache_beam/transforms/userstate.py | 5 +-
sdks/python/apache_beam/transforms/util.py | 9 -
sdks/python/apache_beam/utils/annotations.py | 33 +-
sdks/python/apache_beam/utils/annotations_test.py | 92 -----
sdks/python/apache_beam/utils/histogram.py | 3 -
sdks/python/apache_beam/utils/interactive_utils.py | 5 +-
sdks/python/apache_beam/utils/plugin.py | 5 +-
sdks/python/apache_beam/utils/windowed_value.py | 5 +-
sdks/python/apache_beam/yaml/yaml_transform.py | 2 -
543 files changed, 1008 insertions(+), 2936 deletions(-)
delete mode 100644 sdks/java/core/src/main/java/org/apache/beam/sdk/annotations/Experimental.java
delete mode 100644 sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/annotation/stability/Experimental.java
delete mode 100644 sdks/java/extensions/euphoria/src/main/java/org/apache/beam/sdk/extensions/euphoria/core/annotation/stability/package-info.java
[beam] 01/01: Merge pull request #26490: Remove experimental annotation from Beam
Posted by ke...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 25f9a28596c4a725461b8d3000f9fd3d6c87ad45
Merge: ea2befd9832 459e166abc4
Author: Kenneth Knowles <ke...@apache.org>
AuthorDate: Tue May 9 15:58:46 2023 -0700
Merge pull request #26490: Remove experimental annotation from Beam
CHANGES.md | 6 +-
.../beam/model/fn_execution/v1/beam_fn_api.proto | 1 -
.../beam/model/pipeline/v1/beam_runner_api.proto | 3 -
.../org/apache/beam/model/pipeline/v1/schema.proto | 1 -
playground/infrastructure/api/v1/api_pb2_grpc.py | 1 -
.../runners/core/construction/CoderTranslator.java | 5 +-
.../beam/runners/core/construction/External.java | 3 -
.../beam/runners/core/metrics/MetricsLogger.java | 3 -
.../beam/runners/dataflow/DataflowRunner.java | 2 -
.../beam/runners/dataflow/DataflowRunnerHooks.java | 2 -
.../options/DataflowPipelineDebugOptions.java | 4 +-
.../dataflow/options/DataflowPipelineOptions.java | 2 -
.../options/DataflowPipelineWorkerPoolOptions.java | 13 +-
.../dataflow/options/DataflowProfilingOptions.java | 4 +-
.../util/RowCoderCloudObjectTranslator.java | 3 -
.../util/SchemaCoderCloudObjectTranslator.java | 3 -
.../dataflow/worker/ContextActivationObserver.java | 2 -
.../runners/samza/util/PipelineJsonRenderer.java | 3 -
.../SparkStructuredStreamingPipelineOptions.java | 2 -
.../SparkStructuredStreamingRunner.java | 2 -
.../beam/runners/spark/SparkPipelineOptions.java | 2 -
.../SparkPortableStreamingPipelineOptions.java | 2 -
.../main/java/org/apache/beam/sdk/Pipeline.java | 3 -
.../java/org/apache/beam/sdk/PipelineResult.java | 3 -
.../apache/beam/sdk/annotations/Experimental.java | 113 ------
.../java/org/apache/beam/sdk/coders/Coder.java | 6 -
.../beam/sdk/coders/CoderProviderRegistrar.java | 2 -
.../java/org/apache/beam/sdk/coders/RowCoder.java | 3 -
.../apache/beam/sdk/coders/RowCoderGenerator.java | 3 -
.../sdk/expansion/ExternalTransformRegistrar.java | 3 -
.../apache/beam/sdk/expansion/package-info.java | 3 -
.../apache/beam/sdk/harness/JvmInitializer.java | 2 -
.../main/java/org/apache/beam/sdk/io/AvroIO.java | 21 --
.../java/org/apache/beam/sdk/io/AvroSource.java | 6 +-
.../org/apache/beam/sdk/io/BlockBasedSource.java | 5 -
.../java/org/apache/beam/sdk/io/BoundedSource.java | 3 -
.../apache/beam/sdk/io/ClassLoaderFileSystem.java | 2 -
.../org/apache/beam/sdk/io/CompressedSource.java | 3 -
.../java/org/apache/beam/sdk/io/FileBasedSink.java | 21 --
.../main/java/org/apache/beam/sdk/io/FileIO.java | 3 -
.../java/org/apache/beam/sdk/io/FileSystem.java | 3 -
.../apache/beam/sdk/io/FileSystemRegistrar.java | 3 -
.../java/org/apache/beam/sdk/io/FileSystems.java | 3 -
.../org/apache/beam/sdk/io/GenerateSequence.java | 4 -
.../beam/sdk/io/LocalFileSystemRegistrar.java | 3 -
.../org/apache/beam/sdk/io/LocalResources.java | 3 -
.../beam/sdk/io/ReadAllViaFileBasedSource.java | 3 -
.../sdk/io/ReadAllViaFileBasedSourceTransform.java | 2 -
.../io/ReadAllViaFileBasedSourceWithFilename.java | 2 -
.../org/apache/beam/sdk/io/ShardingFunction.java | 3 -
.../main/java/org/apache/beam/sdk/io/Source.java | 3 -
.../java/org/apache/beam/sdk/io/TFRecordIO.java | 4 -
.../main/java/org/apache/beam/sdk/io/TextIO.java | 13 -
.../org/apache/beam/sdk/io/UnboundedSource.java | 3 -
.../java/org/apache/beam/sdk/io/WriteFiles.java | 3 -
.../org/apache/beam/sdk/io/fs/MatchResult.java | 3 -
.../org/apache/beam/sdk/io/fs/MetadataCoderV2.java | 3 -
.../java/org/apache/beam/sdk/io/fs/ResourceId.java | 3 -
.../apache/beam/sdk/io/fs/ResourceIdTester.java | 3 -
.../java/org/apache/beam/sdk/metrics/Counter.java | 4 -
.../org/apache/beam/sdk/metrics/Distribution.java | 4 -
.../beam/sdk/metrics/DistributionResult.java | 3 -
.../java/org/apache/beam/sdk/metrics/Gauge.java | 4 -
.../org/apache/beam/sdk/metrics/GaugeResult.java | 3 -
.../org/apache/beam/sdk/metrics/Histogram.java | 3 -
.../java/org/apache/beam/sdk/metrics/Metric.java | 3 -
.../org/apache/beam/sdk/metrics/MetricKey.java | 3 -
.../org/apache/beam/sdk/metrics/MetricName.java | 3 -
.../apache/beam/sdk/metrics/MetricNameFilter.java | 3 -
.../beam/sdk/metrics/MetricQueryResults.java | 3 -
.../org/apache/beam/sdk/metrics/MetricResult.java | 3 -
.../org/apache/beam/sdk/metrics/MetricResults.java | 3 -
.../java/org/apache/beam/sdk/metrics/Metrics.java | 3 -
.../apache/beam/sdk/metrics/MetricsContainer.java | 3 -
.../beam/sdk/metrics/MetricsEnvironment.java | 3 -
.../org/apache/beam/sdk/metrics/MetricsFilter.java | 3 -
.../apache/beam/sdk/metrics/MetricsOptions.java | 3 -
.../org/apache/beam/sdk/metrics/MetricsSink.java | 3 -
.../org/apache/beam/sdk/metrics/SinkMetrics.java | 4 -
.../org/apache/beam/sdk/metrics/SourceMetrics.java | 3 -
.../org/apache/beam/sdk/metrics/package-info.java | 3 -
.../beam/sdk/options/ExperimentalOptions.java | 4 +-
.../beam/sdk/options/FileStagingOptions.java | 2 -
.../options/ManualDockerEnvironmentOptions.java | 3 -
.../beam/sdk/options/PipelineOptionsFactory.java | 6 +-
.../beam/sdk/options/PortablePipelineOptions.java | 3 -
.../beam/sdk/options/RemoteEnvironmentOptions.java | 3 -
.../apache/beam/sdk/options/SdkHarnessOptions.java | 3 -
.../apache/beam/sdk/runners/PTransformMatcher.java | 3 -
.../sdk/runners/PTransformOverrideFactory.java | 3 -
.../apache/beam/sdk/schemas/AutoValueSchema.java | 3 -
.../java/org/apache/beam/sdk/schemas/Factory.java | 3 -
.../beam/sdk/schemas/FieldAccessDescriptor.java | 3 -
.../beam/sdk/schemas/FieldTypeDescriptors.java | 3 -
.../beam/sdk/schemas/FromRowUsingCreator.java | 3 -
.../sdk/schemas/GetterBasedSchemaProvider.java | 3 -
.../apache/beam/sdk/schemas/JavaBeanSchema.java | 4 -
.../apache/beam/sdk/schemas/JavaFieldSchema.java | 3 -
.../beam/sdk/schemas/NoSuchSchemaException.java | 4 -
.../beam/sdk/schemas/ProjectionConsumer.java | 2 -
.../beam/sdk/schemas/ProjectionProducer.java | 2 -
.../java/org/apache/beam/sdk/schemas/Schema.java | 3 -
.../org/apache/beam/sdk/schemas/SchemaCoder.java | 3 -
.../apache/beam/sdk/schemas/SchemaProvider.java | 3 -
.../beam/sdk/schemas/SchemaProviderRegistrar.java | 3 -
.../apache/beam/sdk/schemas/SchemaRegistry.java | 3 -
.../apache/beam/sdk/schemas/SchemaTranslation.java | 3 -
.../sdk/schemas/annotations/DefaultSchema.java | 3 -
.../sdk/schemas/annotations/SchemaCaseFormat.java | 3 -
.../beam/sdk/schemas/annotations/SchemaCreate.java | 3 -
.../annotations/SchemaFieldDescription.java | 3 -
.../sdk/schemas/annotations/SchemaFieldName.java | 3 -
.../sdk/schemas/annotations/SchemaFieldNumber.java | 3 -
.../beam/sdk/schemas/annotations/SchemaIgnore.java | 3 -
.../beam/sdk/schemas/io/DeadLetteredTransform.java | 3 -
.../org/apache/beam/sdk/schemas/io/Failure.java | 3 -
.../org/apache/beam/sdk/schemas/io/GenericDlq.java | 3 -
.../beam/sdk/schemas/io/GenericDlqProvider.java | 3 -
.../schemas/io/InvalidConfigurationException.java | 3 -
.../sdk/schemas/io/InvalidLocationException.java | 3 -
.../sdk/schemas/io/InvalidSchemaException.java | 3 -
.../org/apache/beam/sdk/schemas/io/Providers.java | 3 -
.../org/apache/beam/sdk/schemas/io/SchemaIO.java | 3 -
.../beam/sdk/schemas/io/SchemaIOProvider.java | 3 -
.../io/payloads/AvroPayloadSerializerProvider.java | 3 -
.../io/payloads/JsonPayloadSerializerProvider.java | 3 -
.../sdk/schemas/io/payloads/PayloadSerializer.java | 3 -
.../io/payloads/PayloadSerializerProvider.java | 3 -
.../schemas/io/payloads/PayloadSerializers.java | 3 -
.../sdk/schemas/logicaltypes/EnumerationType.java | 3 -
.../beam/sdk/schemas/logicaltypes/OneOfType.java | 3 -
.../logicaltypes/PassThroughLogicalType.java | 3 -
.../sdk/schemas/logicaltypes/PythonCallable.java | 2 -
.../sdk/schemas/logicaltypes/UuidLogicalType.java | 3 -
.../org/apache/beam/sdk/schemas/package-info.java | 3 -
.../beam/sdk/schemas/transforms/AddFields.java | 3 -
.../apache/beam/sdk/schemas/transforms/Cast.java | 3 -
.../beam/sdk/schemas/transforms/CoGroup.java | 3 -
.../beam/sdk/schemas/transforms/Convert.java | 3 -
.../beam/sdk/schemas/transforms/DropFields.java | 3 -
.../apache/beam/sdk/schemas/transforms/Filter.java | 3 -
.../apache/beam/sdk/schemas/transforms/Group.java | 3 -
.../apache/beam/sdk/schemas/transforms/Join.java | 3 -
.../beam/sdk/schemas/transforms/RenameFields.java | 3 -
.../sdk/schemas/transforms/SchemaAggregateFn.java | 3 -
.../sdk/schemas/transforms/SchemaTransform.java | 3 -
.../transforms/SchemaTransformProvider.java | 3 -
.../apache/beam/sdk/schemas/transforms/Select.java | 3 -
.../transforms/TypedSchemaTransformProvider.java | 3 -
.../beam/sdk/schemas/utils/AutoValueUtils.java | 3 -
.../beam/sdk/schemas/utils/AvroByteBuddyUtils.java | 3 -
.../apache/beam/sdk/schemas/utils/AvroUtils.java | 3 -
.../beam/sdk/schemas/utils/ConvertHelpers.java | 3 -
.../sdk/schemas/utils/FieldValueTypeSupplier.java | 3 -
.../beam/sdk/schemas/utils/JavaBeanUtils.java | 3 -
.../apache/beam/sdk/schemas/utils/JsonUtils.java | 3 -
.../apache/beam/sdk/schemas/utils/POJOUtils.java | 3 -
.../beam/sdk/schemas/utils/ReflectUtils.java | 3 -
.../beam/sdk/schemas/utils/SchemaZipFold.java | 3 -
.../beam/sdk/schemas/utils/SelectHelpers.java | 3 -
.../sdk/schemas/utils/StaticSchemaInference.java | 3 -
.../java/org/apache/beam/sdk/state/BagState.java | 3 -
.../org/apache/beam/sdk/state/CombiningState.java | 3 -
.../org/apache/beam/sdk/state/GroupingState.java | 3 -
.../java/org/apache/beam/sdk/state/MapState.java | 3 -
.../org/apache/beam/sdk/state/MultimapState.java | 3 -
.../apache/beam/sdk/state/OrderedListState.java | 3 -
.../org/apache/beam/sdk/state/ReadableState.java | 4 -
.../java/org/apache/beam/sdk/state/SetState.java | 4 -
.../main/java/org/apache/beam/sdk/state/State.java | 4 -
.../org/apache/beam/sdk/state/StateKeySpec.java | 4 -
.../java/org/apache/beam/sdk/state/StateSpec.java | 3 -
.../java/org/apache/beam/sdk/state/StateSpecs.java | 3 -
.../java/org/apache/beam/sdk/state/TimeDomain.java | 3 -
.../main/java/org/apache/beam/sdk/state/Timer.java | 3 -
.../java/org/apache/beam/sdk/state/TimerMap.java | 3 -
.../java/org/apache/beam/sdk/state/TimerSpec.java | 3 -
.../java/org/apache/beam/sdk/state/TimerSpecs.java | 3 -
.../java/org/apache/beam/sdk/state/Timers.java | 3 -
.../java/org/apache/beam/sdk/state/ValueState.java | 3 -
.../org/apache/beam/sdk/state/package-info.java | 3 -
.../org/apache/beam/sdk/testing/TestStream.java | 4 -
.../org/apache/beam/sdk/transforms/Contextful.java | 3 -
.../org/apache/beam/sdk/transforms/Create.java | 6 -
.../java/org/apache/beam/sdk/transforms/DoFn.java | 25 +-
.../beam/sdk/transforms/DoFnSchemaInformation.java | 3 -
.../sdk/transforms/ExternalTransformBuilder.java | 3 -
.../beam/sdk/transforms/FlatMapElements.java | 6 -
.../beam/sdk/transforms/GroupIntoBatches.java | 2 -
.../org/apache/beam/sdk/transforms/JsonToRow.java | 10 +-
.../apache/beam/sdk/transforms/MapElements.java | 6 -
.../beam/sdk/transforms/Materializations.java | 4 -
.../org/apache/beam/sdk/transforms/PTransform.java | 3 -
.../apache/beam/sdk/transforms/Requirements.java | 3 -
.../org/apache/beam/sdk/transforms/Reshuffle.java | 2 -
.../org/apache/beam/sdk/transforms/ToJson.java | 6 +-
.../java/org/apache/beam/sdk/transforms/Wait.java | 2 -
.../apache/beam/sdk/transforms/WithFailures.java | 3 -
.../beam/sdk/transforms/windowing/AfterAll.java | 3 -
.../beam/sdk/transforms/windowing/AfterEach.java | 3 -
.../beam/sdk/transforms/windowing/AfterFirst.java | 3 -
.../beam/sdk/transforms/windowing/AfterPane.java | 3 -
.../transforms/windowing/AfterProcessingTime.java | 3 -
.../sdk/transforms/windowing/AfterWatermark.java | 3 -
.../sdk/transforms/windowing/DefaultTrigger.java | 3 -
.../transforms/windowing/TimestampCombiner.java | 3 -
.../beam/sdk/transforms/windowing/Trigger.java | 3 -
.../beam/sdk/transforms/windowing/Window.java | 17 +-
.../sdk/transforms/windowing/WindowMappingFn.java | 7 +-
.../org/apache/beam/sdk/util/HistogramData.java | 5 -
.../java/org/apache/beam/sdk/util/RowJson.java | 3 -
.../org/apache/beam/sdk/values/PCollection.java | 8 -
.../apache/beam/sdk/values/PCollectionView.java | 3 -
.../apache/beam/sdk/values/PCollectionViews.java | 11 -
.../main/java/org/apache/beam/sdk/values/Row.java | 3 -
.../org/apache/beam/sdk/values/RowWithGetters.java | 3 -
.../org/apache/beam/sdk/values/RowWithStorage.java | 3 -
.../apache/beam/sdk/values/SchemaVerification.java | 2 -
.../apache/beam/sdk/values/WindowingStrategy.java | 13 +-
.../beam/sdk/extensions/arrow/ArrowConversion.java | 2 -
.../sdk/extensions/avro/coders/package-info.java | 3 -
.../apache/beam/sdk/extensions/avro/io/AvroIO.java | 21 --
.../beam/sdk/extensions/avro/io/AvroSource.java | 6 +-
.../beam/sdk/extensions/avro/io/package-info.java | 3 -
.../io/payloads/AvroPayloadSerializerProvider.java | 3 -
.../avro/schemas/io/payloads/package-info.java | 3 -
.../sdk/extensions/avro/schemas/package-info.java | 3 -
.../avro/schemas/utils/AvroByteBuddyUtils.java | 3 -
.../extensions/avro/schemas/utils/AvroUtils.java | 3 -
.../avro/schemas/utils/package-info.java | 3 -
.../core/annotation/stability/Experimental.java | 44 ---
.../core/annotation/stability/package-info.java | 19 -
.../core/translate/provider/CompositeProvider.java | 2 -
.../provider/GenericTranslatorProvider.java | 2 -
.../sdk/extensions/gcp/options/GcpOptions.java | 2 -
.../sdk/extensions/gcp/options/GcsOptions.java | 5 +-
.../gcp/storage/GcsFileSystemRegistrar.java | 3 -
.../sdk/extensions/gcp/storage/package-info.java | 4 -
.../beam/sdk/extensions/jackson/AsJsons.java | 5 -
.../beam/sdk/extensions/jackson/ParseJsons.java | 5 -
.../apache/beam/sdk/extensions/kryo/KryoCoder.java | 2 -
.../sdk/extensions/kryo/KryoCoderProvider.java | 2 -
.../beam/sdk/extensions/kryo/KryoOptions.java | 2 -
.../beam/sdk/extensions/kryo/KryoRegistrar.java | 2 -
.../beam/sdk/extensions/ml/AnnotateImages.java | 2 -
.../beam/sdk/extensions/ml/AnnotateText.java | 2 -
.../ml/AnnotateVideoBytesWithContextFn.java | 2 -
.../beam/sdk/extensions/ml/AnnotateVideoFn.java | 2 -
.../extensions/ml/AnnotateVideoFromBytesFn.java | 2 -
.../sdk/extensions/ml/AnnotateVideoFromURIFn.java | 2 -
.../ml/AnnotateVideoURIWithContextFn.java | 2 -
.../beam/sdk/extensions/ml/BatchRequestForDLP.java | 3 +-
.../apache/beam/sdk/extensions/ml/CloudVision.java | 2 -
.../beam/sdk/extensions/ml/DLPDeidentifyText.java | 2 -
.../beam/sdk/extensions/ml/DLPInspectText.java | 2 -
.../beam/sdk/extensions/ml/DLPReidentifyText.java | 2 -
.../beam/sdk/extensions/ml/VideoIntelligence.java | 6 -
.../beam/sdk/extensions/ml/package-info.java | 3 -
.../extensions/protobuf/ProtoByteBuddyUtils.java | 6 -
.../protobuf/ProtoDynamicMessageSchema.java | 2 -
.../extensions/protobuf/ProtoMessageSchema.java | 3 -
.../protobuf/ProtoPayloadSerializerProvider.java | 3 -
.../protobuf/ProtoSchemaLogicalTypes.java | 3 -
.../python/transforms/DataframeTransform.java | 2 +-
.../extensions/python/transforms/PythonMap.java | 2 +-
.../extensions/python/transforms/RunInference.java | 2 +-
.../beam/sdk/extensions/sbe/IrFieldGenerator.java | 3 -
.../beam/sdk/extensions/sbe/PrimitiveSbeField.java | 3 -
.../apache/beam/sdk/extensions/sbe/SbeField.java | 3 -
.../beam/sdk/extensions/sbe/SbeLogicalTypes.java | 3 -
.../apache/beam/sdk/extensions/sbe/SbeSchema.java | 3 -
.../beam/sdk/extensions/sbe/SerializableIr.java | 3 -
.../beam/sdk/extensions/sbe/package-info.java | 4 -
.../ExternalSchemaIOTransformRegistrar.java | 2 -
.../extensions/sketching/ApproximateDistinct.java | 6 -
.../extensions/sketching/SketchFrequencies.java | 5 -
.../sdk/extensions/sketching/TDigestQuantiles.java | 5 -
.../sdk/extensions/sketching/package-info.java | 3 -
.../sdk/extensions/sql/example/package-info.java | 3 -
.../sql/meta/provider/datacatalog/SchemaUtils.java | 3 -
.../meta/provider/datacatalog/package-info.java | 3 -
.../SqlTransformSchemaTransformProvider.java | 2 -
.../sql/meta/provider/hcatalog/HCatalogTable.java | 2 -
.../sql/meta/provider/hcatalog/package-info.java | 3 -
sdks/java/extensions/sql/jdbc/build.gradle | 1 -
.../beam/sdk/extensions/sql/jdbc/package-info.java | 3 -
.../apache/beam/sdk/extensions/sql/BeamSqlCli.java | 2 -
.../sdk/extensions/sql/BeamSqlSeekableTable.java | 2 -
.../apache/beam/sdk/extensions/sql/BeamSqlUdf.java | 2 -
.../beam/sdk/extensions/sql/SqlTransform.java | 15 +-
.../sdk/extensions/sql/TypedCombineFnDelegate.java | 2 -
.../beam/sdk/extensions/sql/impl/BeamSqlEnv.java | 2 -
.../extensions/sql/impl/BeamTableStatistics.java | 2 -
.../beam/sdk/extensions/sql/impl/UdafImpl.java | 2 -
.../sdk/extensions/sql/impl/udaf/StringAgg.java | 2 -
.../sql/meta/provider/FullNameTableProvider.java | 2 -
.../provider/SchemaIOTableProviderWrapper.java | 2 -
.../sql/meta/provider/UdfUdafProvider.java | 2 -
.../sql/meta/provider/bigquery/BigQueryTable.java | 2 -
.../sql/meta/provider/bigtable/BigtableTable.java | 2 -
.../provider/bigtable/BigtableTableProvider.java | 2 -
.../sql/meta/provider/mongodb/MongoDbTable.java | 2 -
.../meta/provider/pubsub/PubsubTableProvider.java | 2 -
.../sql/meta/provider/test/TestBoundedTable.java | 2 -
.../sql/meta/provider/test/TestTable.java | 2 -
.../sql/meta/provider/test/TestTableUtils.java | 2 -
.../sql/meta/provider/test/TestUnboundedTable.java | 2 -
.../beam/sdk/extensions/sql/udf/AggregateFn.java | 3 -
.../beam/sdk/extensions/sql/udf/ScalarFn.java | 3 -
.../beam/sdk/extensions/sql/udf/package-info.java | 2 +-
.../sdk/extensions/sql/zetasql/package-info.java | 3 -
.../sql/zetasql/translation/impl/package-info.java | 3 -
.../sql/zetasql/translation/package-info.java | 3 -
.../sql/zetasql/unnest/package-info.java | 3 -
.../zetasketch/ApproximateCountDistinct.java | 2 -
.../beam/sdk/extensions/zetasketch/HllCount.java | 2 -
.../sdk/extensions/zetasketch/package-info.java | 3 -
.../java/org/apache/beam/fn/harness/Cache.java | 3 -
.../beam/sdk/io/aws/dynamodb/DynamoDBIO.java | 3 -
.../beam/sdk/io/aws/dynamodb/package-info.java | 4 -
.../beam/sdk/io/aws/options/package-info.java | 4 -
.../aws/s3/DefaultS3FileSystemSchemeRegistrar.java | 3 -
.../sdk/io/aws/s3/S3FileSystemConfiguration.java | 3 -
.../beam/sdk/io/aws/s3/S3FileSystemRegistrar.java | 3 -
.../sdk/io/aws/s3/S3FileSystemSchemeRegistrar.java | 3 -
.../apache/beam/sdk/io/aws/s3/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/aws/sns/SnsIO.java | 3 -
.../apache/beam/sdk/io/aws/sns/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/aws/sqs/SqsIO.java | 3 -
.../apache/beam/sdk/io/aws/sqs/package-info.java | 4 -
.../apache/beam/sdk/io/aws2/common/ObjectPool.java | 2 -
.../beam/sdk/io/aws2/common/package-info.java | 4 -
.../beam/sdk/io/aws2/dynamodb/DynamoDBIO.java | 3 -
.../beam/sdk/io/aws2/dynamodb/package-info.java | 4 -
.../apache/beam/sdk/io/aws2/kinesis/KinesisIO.java | 3 -
.../beam/sdk/io/aws2/kinesis/KinesisIOOptions.java | 3 -
.../beam/sdk/io/aws2/kinesis/package-info.java | 4 -
.../apache/beam/sdk/io/aws2/options/AwsModule.java | 3 -
.../beam/sdk/io/aws2/options/AwsOptions.java | 3 -
.../beam/sdk/io/aws2/options/package-info.java | 4 -
.../s3/DefaultS3FileSystemSchemeRegistrar.java | 3 -
.../sdk/io/aws2/s3/S3FileSystemConfiguration.java | 3 -
.../beam/sdk/io/aws2/s3/S3FileSystemRegistrar.java | 3 -
.../io/aws2/s3/S3FileSystemSchemeRegistrar.java | 3 -
.../apache/beam/sdk/io/aws2/s3/package-info.java | 4 -
.../beam/sdk/io/aws2/schemas/package-info.java | 4 -
.../org/apache/beam/sdk/io/aws2/sns/SnsIO.java | 3 -
.../apache/beam/sdk/io/aws2/sns/package-info.java | 4 -
.../org/apache/beam/sdk/io/aws2/sqs/SqsIO.java | 3 -
.../apache/beam/sdk/io/aws2/sqs/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/amqp/AmqpIO.java | 3 -
.../org/apache/beam/sdk/io/amqp/package-info.java | 4 -
.../AzureBlobStoreFileSystemRegistrar.java | 2 -
.../beam/sdk/io/azure/blobstore/package-info.java | 4 -
.../sdk/io/azure/options/BlobstoreOptions.java | 3 -
.../beam/sdk/io/azure/options/package-info.java | 4 -
.../apache/beam/sdk/io/cassandra/CassandraIO.java | 3 -
.../org/apache/beam/sdk/io/cassandra/Mapper.java | 3 -
.../apache/beam/sdk/io/cassandra/RingRange.java | 3 -
.../apache/beam/sdk/io/cassandra/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/cdap/CdapIO.java | 5 -
.../beam/sdk/io/cdap/context/package-info.java | 4 -
.../org/apache/beam/sdk/io/cdap/package-info.java | 4 -
.../beam/sdk/io/clickhouse/ClickHouseIO.java | 3 -
.../beam/sdk/io/clickhouse/ClickHouseWriter.java | 3 -
.../apache/beam/sdk/io/clickhouse/TableSchema.java | 3 -
.../beam/sdk/io/clickhouse/package-info.java | 4 -
.../beam/sdk/io/contextualtextio/package-info.java | 3 -
.../org/apache/beam/io/debezium/DebeziumIO.java | 3 -
.../io/debezium/DebeziumTransformRegistrar.java | 2 -
.../org/apache/beam/io/debezium/package-info.java | 4 -
.../beam/sdk/io/elasticsearch/ElasticsearchIO.java | 3 -
.../beam/sdk/io/elasticsearch/package-info.java | 4 -
.../BigQueryExportReadSchemaTransformProvider.java | 3 -
...QueryFileLoadsWriteSchemaTransformProvider.java | 3 -
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 22 +-
.../beam/sdk/io/gcp/bigquery/BigQueryOptions.java | 3 -
.../io/gcp/bigquery/BigQueryQuerySourceDef.java | 3 -
.../io/gcp/bigquery/BigQuerySchemaIOProvider.java | 4 -
.../sdk/io/gcp/bigquery/BigQuerySourceDef.java | 3 -
.../io/gcp/bigquery/BigQueryTableSourceDef.java | 3 -
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 10 -
.../beam/sdk/io/gcp/bigquery/TestBigQuery.java | 7 -
.../BigQueryDirectReadSchemaTransformProvider.java | 3 -
...ueryStorageWriteApiSchemaTransformProvider.java | 3 -
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 4 -
.../changestreams/action/package-info.java | 3 -
.../bigtable/changestreams/dao/package-info.java | 3 -
.../bigtable/changestreams/dofn/package-info.java | 3 -
.../changestreams/encoder/package-info.java | 2 -
.../changestreams/estimator/package-info.java | 2 -
.../bigtable/changestreams/model/package-info.java | 3 -
.../gcp/bigtable/changestreams/package-info.java | 3 -
.../changestreams/reconciler/package-info.java | 2 -
.../changestreams/restriction/package-info.java | 3 -
.../beam/sdk/io/gcp/bigtable/package-info.java | 4 -
.../beam/sdk/io/gcp/datastore/package-info.java | 4 -
.../beam/sdk/io/gcp/firestore/FirestoreIO.java | 4 -
.../beam/sdk/io/gcp/firestore/FirestoreV1.java | 4 -
.../beam/sdk/io/gcp/firestore/package-info.java | 4 -
.../beam/sdk/io/gcp/healthcare/package-info.java | 4 -
.../beam/sdk/io/gcp/pubsub/ExternalRead.java | 2 -
.../beam/sdk/io/gcp/pubsub/ExternalWrite.java | 2 -
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 8 -
.../beam/sdk/io/gcp/pubsub/PubsubMessageToRow.java | 2 -
.../PubsubReadSchemaTransformConfiguration.java | 2 -
.../pubsub/PubsubReadSchemaTransformProvider.java | 3 -
.../beam/sdk/io/gcp/pubsub/PubsubRowToMessage.java | 2 -
.../PubsubSchemaTransformMessageToRowFactory.java | 3 -
.../beam/sdk/io/gcp/pubsub/PubsubTestClient.java | 2 -
.../PubsubWriteSchemaTransformConfiguration.java | 2 -
.../pubsub/PubsubWriteSchemaTransformProvider.java | 3 -
.../beam/sdk/io/gcp/pubsublite/PubsubLiteIO.java | 2 -
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 9 +-
.../io/gcp/spanner/SpannerTransformRegistrar.java | 10 -
.../spanner/changestreams/action/package-info.java | 3 -
.../spanner/changestreams/dao/package-info.java | 3 -
.../spanner/changestreams/dofn/package-info.java | 3 -
.../changestreams/encoder/package-info.java | 3 -
.../changestreams/estimator/package-info.java | 3 -
.../spanner/changestreams/mapper/package-info.java | 3 -
.../spanner/changestreams/model/package-info.java | 3 -
.../io/gcp/spanner/changestreams/package-info.java | 4 -
.../changestreams/restriction/package-info.java | 3 -
.../beam/sdk/io/gcp/spanner/package-info.java | 4 -
.../beam/sdk/io/gcp/testing/BigqueryMatcher.java | 2 -
.../apache/beam/sdk/io/hadoop/package-info.java | 4 -
.../beam/sdk/io/hdfs/HadoopFileSystemOptions.java | 3 -
.../sdk/io/hdfs/HadoopFileSystemRegistrar.java | 3 -
.../org/apache/beam/sdk/io/hdfs/package-info.java | 4 -
.../beam/sdk/io/hadoop/format/HadoopFormatIO.java | 3 -
.../beam/sdk/io/hadoop/format/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/hbase/HBaseIO.java | 9 -
.../org/apache/beam/sdk/io/hbase/package-info.java | 4 -
.../org/apache/beam/sdk/io/hcatalog/HCatToRow.java | 3 -
.../beam/sdk/io/hcatalog/HCatalogBeamSchema.java | 3 -
.../apache/beam/sdk/io/hcatalog/HCatalogIO.java | 3 -
.../apache/beam/sdk/io/hcatalog/SchemaUtils.java | 3 -
.../apache/beam/sdk/io/hcatalog/package-info.java | 4 -
.../apache/beam/sdk/io/influxdb/InfluxDbIO.java | 3 -
.../org/apache/beam/sdk/io/jdbc/LogicalTypes.java | 3 -
.../org/apache/beam/sdk/io/jdbc/SchemaUtil.java | 3 -
.../org/apache/beam/sdk/io/jdbc/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 3 -
.../org/apache/beam/sdk/io/jms/package-info.java | 4 -
...onfluentSchemaRegistryDeserializerProvider.java | 3 -
.../beam/sdk/io/kafka/DeserializerProvider.java | 3 -
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 10 -
.../KafkaReadSchemaTransformConfiguration.java | 2 -
.../sdk/io/kafka/WatchForKafkaTopicPartitions.java | 2 -
.../org/apache/beam/sdk/io/kafka/package-info.java | 4 -
.../kafka/serialization/InstantDeserializer.java | 3 -
.../io/kafka/serialization/InstantSerializer.java | 3 -
.../sdk/io/kafka/serialization/package-info.java | 4 -
.../org/apache/beam/sdk/io/kinesis/KinesisIO.java | 3 -
.../sdk/io/kinesis/KinesisTransformRegistrar.java | 3 -
.../apache/beam/sdk/io/kinesis/package-info.java | 4 -
.../beam/sdk/io/kinesis/serde/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/kudu/KuduIO.java | 7 +-
.../org/apache/beam/sdk/io/kudu/package-info.java | 4 -
.../beam/sdk/io/mongodb/AggregationQuery.java | 3 -
.../org/apache/beam/sdk/io/mongodb/FindQuery.java | 3 -
.../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 3 -
.../org/apache/beam/sdk/io/mongodb/MongoDbIO.java | 3 -
.../beam/sdk/io/mongodb/UpdateConfiguration.java | 3 -
.../apache/beam/sdk/io/mongodb/UpdateField.java | 3 -
.../apache/beam/sdk/io/mongodb/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/mqtt/MqttIO.java | 3 -
.../org/apache/beam/sdk/io/mqtt/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/neo4j/Neo4jIO.java | 2 -
.../org/apache/beam/sdk/io/neo4j/package-info.java | 4 -
.../org/apache/beam/sdk/io/parquet/ParquetIO.java | 9 -
.../apache/beam/sdk/io/parquet/package-info.java | 4 -
.../apache/beam/sdk/io/rabbitmq/RabbitMqIO.java | 3 -
.../apache/beam/sdk/io/rabbitmq/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/redis/RedisIO.java | 3 -
.../org/apache/beam/sdk/io/redis/package-info.java | 4 -
.../beam/sdk/io/singlestore/package-info.java | 4 -
.../apache/beam/sdk/io/snowflake/SnowflakeIO.java | 2 -
.../io/snowflake/crosslanguage/ReadBuilder.java | 3 -
.../crosslanguage/SnowflakeTransformRegistrar.java | 3 -
.../io/snowflake/crosslanguage/WriteBuilder.java | 3 -
.../io/snowflake/crosslanguage/package-info.java | 3 -
.../java/org/apache/beam/sdk/io/solr/SolrIO.java | 3 -
.../org/apache/beam/sdk/io/solr/package-info.java | 4 -
.../beam/sdk/io/sparkreceiver/SparkReceiverIO.java | 3 -
.../beam/sdk/io/sparkreceiver/package-info.java | 4 -
.../org/apache/beam/sdk/io/splunk/SplunkIO.java | 3 -
.../apache/beam/sdk/io/splunk/package-info.java | 4 -
.../sdk/io/synthetic/SyntheticBoundedSource.java | 3 -
.../sdk/io/synthetic/SyntheticUnboundedSource.java | 3 -
.../beam/sdk/io/synthetic/delay/package-info.java | 4 -
.../apache/beam/sdk/io/synthetic/package-info.java | 4 -
.../org/apache/beam/sdk/io/thrift/ThriftIO.java | 6 -
.../io/thrift/ThriftPayloadSerializerProvider.java | 3 -
.../apache/beam/sdk/io/thrift/ThriftSchema.java | 2 -
.../apache/beam/sdk/io/thrift/package-info.java | 4 -
.../java/org/apache/beam/sdk/io/tika/TikaIO.java | 3 -
.../org/apache/beam/sdk/io/tika/package-info.java | 4 -
.../org/apache/beam/sdk/io/xml/package-info.java | 4 -
.../coders/proto2_coder_test_messages_pb2.py | 35 +-
sdks/python/apache_beam/internal/metrics/metric.py | 5 +-
sdks/python/apache_beam/io/fileio.py | 3 -
sdks/python/apache_beam/io/gcp/bigquery.py | 2 -
.../apache_beam/io/gcp/experimental/spannerio.py | 3 -
.../clients/bigquery/bigquery_v2_client.py | 260 +++++++------
.../clients/bigquery/bigquery_v2_messages.py | 223 +++++------
.../internal/clients/storage/storage_v1_client.py | 410 +++++++++++++--------
.../clients/storage/storage_v1_messages.py | 78 ++--
sdks/python/apache_beam/io/mongodbio.py | 3 -
sdks/python/apache_beam/metrics/metric.py | 2 -
sdks/python/apache_beam/ml/gcp/cloud_dlp.py | 3 -
.../apache_beam/ml/inference/pytorch_inference.py | 2 -
.../apache_beam/ml/inference/sklearn_inference.py | 2 -
.../apache_beam/ml/inference/tensorrt_inference.py | 2 -
.../python/apache_beam/options/pipeline_options.py | 2 -
.../clients/cloudbuild/cloudbuild_v1_messages.py | 2 +-
.../clients/dataflow/dataflow_v1b3_client.py | 375 ++++++++++---------
.../clients/dataflow/dataflow_v1b3_messages.py | 395 ++++++++++----------
.../apache_beam/runners/direct/direct_runner.py | 2 -
.../apache_beam/runners/worker/bundle_processor.py | 1 -
.../apache_beam/runners/worker/data_plane.py | 2 -
.../apache_beam/runners/worker/log_handler.py | 2 -
sdks/python/apache_beam/runners/worker/logger.py | 2 -
.../apache_beam/runners/worker/opcounters.py | 2 -
.../apache_beam/runners/worker/operation_specs.py | 2 -
.../apache_beam/runners/worker/sdk_worker_main.py | 2 -
.../apache_beam/runners/worker/sideinputs.py | 2 -
.../apache_beam/runners/worker/statesampler.py | 2 -
.../runners/worker/statesampler_slow.py | 2 -
sdks/python/apache_beam/transforms/core.py | 4 -
sdks/python/apache_beam/transforms/external.py | 7 +-
sdks/python/apache_beam/transforms/ptransform.py | 3 -
sdks/python/apache_beam/transforms/trigger.py | 12 +-
sdks/python/apache_beam/transforms/userstate.py | 5 +-
sdks/python/apache_beam/transforms/util.py | 9 -
sdks/python/apache_beam/utils/annotations.py | 33 +-
sdks/python/apache_beam/utils/annotations_test.py | 92 -----
sdks/python/apache_beam/utils/histogram.py | 3 -
sdks/python/apache_beam/utils/interactive_utils.py | 5 +-
sdks/python/apache_beam/utils/plugin.py | 5 +-
sdks/python/apache_beam/utils/windowed_value.py | 5 +-
sdks/python/apache_beam/yaml/yaml_transform.py | 2 -
543 files changed, 1008 insertions(+), 2936 deletions(-)
diff --cc runners/samza/src/main/java/org/apache/beam/runners/samza/util/PipelineJsonRenderer.java
index 8f8d5da06f2,6672f654db8..befe7547d02
--- a/runners/samza/src/main/java/org/apache/beam/runners/samza/util/PipelineJsonRenderer.java
+++ b/runners/samza/src/main/java/org/apache/beam/runners/samza/util/PipelineJsonRenderer.java
@@@ -58,9 -47,7 +57,8 @@@ import org.slf4j.LoggerFactory
* A JSON renderer for BEAM {@link Pipeline} DAG. This can help us with visualization of the Beam
* DAG.
*/
- @Experimental
public class PipelineJsonRenderer implements Pipeline.PipelineVisitor {
+ private static final Logger LOG = LoggerFactory.getLogger(PipelineJsonRenderer.class);
private static final String TRANSFORM_IO_MAP_DELIMITER = ",";
/**