This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 7fc5fb5 Merge pull request #10746: [BEAM-9241] Fix inconsistent proto
nullability
add e96dbf3 [BEAM-9231] Add Experimental(Kind.PORTABILITY) and tag
related classes
add 650e6cd [BEAM-9231] Tag SplittableDoFn related classes/methods as
Experimental
add 9108832 [BEAM-9231] Make Experimental annotations homogeneous in
beam-sdks-java-core
add cb7cb53 [BEAM-9231] Untag Experimental/Internal classes not needed to
write pipelines
add 1574a81 [BEAM-9231] Tag beam-sdks-java-core internal classes as
Internal
add 0b2d2f5 [BEAM-9231] Tag DoFn.OnTimerContext as
Experimental(Kind.TIMERS)
add 486d230 [BEAM-9231] Tag Experimental/Internal packages in
beam-sdks-java-core
add a90ef1a [BEAM-9231] Tag Experimental/Internal packages in IOs and
extensions
add ce35107 [BEAM-9231] Tag public but internal IOs and extensions
classes as Internal
add da9e172 Merge pull request #10739: [BEAM-9231] Annotate as
Experimental/Internal missing classes in beam-sdks-java-core
No new revisions were added by this update.
Summary of changes:
.../runners/core/construction/CoderTranslator.java | 3 --
.../core/construction/CoderTranslators.java | 3 --
.../beam/runners/core/construction/External.java | 3 ++
.../core/construction/PTransformMatchers.java | 3 --
.../runners/core/construction/SdkComponents.java | 2 -
.../runners/core/construction/SplittableParDo.java | 2 -
.../core/construction/TriggerTranslation.java | 2 -
.../core/construction/graph/ProtoOverrides.java | 2 -
.../beam/runners/core/InMemoryStateInternals.java | 3 --
.../beam/runners/core/MergingStateAccessor.java | 3 --
.../apache/beam/runners/core/StateAccessor.java | 3 --
.../apache/beam/runners/core/StateInternals.java | 3 --
.../beam/runners/core/StateInternalsFactory.java | 3 --
.../org/apache/beam/runners/core/StateTag.java | 3 --
.../org/apache/beam/runners/core/StateTags.java | 3 --
.../beam/runners/core/TimerInternalsFactory.java | 3 --
.../beam/runners/core/metrics/CounterCell.java | 5 ---
.../beam/runners/core/metrics/DirtyState.java | 5 ---
.../runners/core/metrics/DistributionCell.java | 5 ---
.../beam/runners/core/metrics/GaugeCell.java | 4 --
.../beam/runners/core/metrics/MetricCell.java | 3 --
.../beam/runners/core/metrics/MetricUpdates.java | 3 --
.../runners/core/metrics/MetricsContainerImpl.java | 3 --
.../beam/runners/core/metrics/MetricsMap.java | 3 --
.../beam/runners/core/metrics/MetricsPusher.java | 2 -
.../runners/core/metrics/MetricsTranslation.java | 3 --
.../core/triggers/AfterAllStateMachine.java | 2 -
.../AfterDelayFromFirstElementStateMachine.java | 2 -
.../core/triggers/AfterFirstStateMachine.java | 2 -
.../core/triggers/AfterPaneStateMachine.java | 2 -
.../triggers/AfterProcessingTimeStateMachine.java | 2 -
.../core/triggers/AfterWatermarkStateMachine.java | 2 -
.../core/triggers/DefaultTriggerStateMachine.java | 2 -
.../java/org/apache/beam/runners/direct/Clock.java | 2 -
.../beam/runners/direct/DirectTestOptions.java | 2 -
.../beam/runners/direct/WatermarkManager.java | 2 -
.../extensions/metrics/MetricsGraphiteSink.java | 2 -
.../extensions/metrics/MetricsHttpSink.java | 2 -
.../beam/runners/dataflow/DataflowRunner.java | 2 -
.../beam/runners/dataflow/TransformTranslator.java | 2 -
.../options/DataflowPipelineWorkerPoolOptions.java | 5 ++-
.../beam/runners/dataflow/util/PackageUtil.java | 2 -
.../jobsubmission/PortablePipelineResult.java | 2 -
.../beam/runners/samza/state/SamzaMapState.java | 2 -
.../beam/runners/samza/state/SamzaSetState.java | 2 -
.../SparkStructuredStreamingRunner.java | 2 -
.../runners/spark/translation/SparkCombineFn.java | 2 -
.../beam/runners/spark/util/SparkCompat.java | 2 -
.../apache/beam/sdk/annotations/Experimental.java | 4 ++
.../org/apache/beam/sdk/annotations/Internal.java | 1 +
.../apache/beam/sdk/annotations/package-info.java | 1 +
.../sdk/expansion/ExternalTransformRegistrar.java | 3 +-
.../apache/beam/sdk/expansion/package-info.java | 3 ++
.../org/apache/beam/sdk/harness/package-info.java | 2 +
.../main/java/org/apache/beam/sdk/io/AvroIO.java | 4 +-
.../java/org/apache/beam/sdk/io/AvroSource.java | 7 ++--
.../org/apache/beam/sdk/io/BlockBasedSource.java | 7 ++--
.../java/org/apache/beam/sdk/io/BoundedSource.java | 3 +-
.../org/apache/beam/sdk/io/CompressedSource.java | 3 +-
.../main/java/org/apache/beam/sdk/io/FileIO.java | 7 ++--
.../beam/sdk/io/ReadAllViaFileBasedSource.java | 3 +-
.../main/java/org/apache/beam/sdk/io/Source.java | 3 +-
.../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 +-
.../apache/beam/sdk/metrics/DelegatingCounter.java | 5 +--
.../java/org/apache/beam/sdk/metrics/Gauge.java | 3 +-
.../apache/beam/sdk/metrics/MetricsOptions.java | 3 +-
.../org/apache/beam/sdk/metrics/MetricsSink.java | 3 +-
.../org/apache/beam/sdk/metrics/package-info.java | 3 ++
.../options/ManualDockerEnvironmentOptions.java | 3 +-
.../beam/sdk/options/PipelineOptionsFactory.java | 2 +-
.../beam/sdk/options/PortablePipelineOptions.java | 3 ++
.../beam/sdk/options/RemoteEnvironmentOptions.java | 3 +-
.../apache/beam/sdk/options/SdkHarnessOptions.java | 3 +-
.../org/apache/beam/sdk/runners/package-info.java | 2 +
.../org/apache/beam/sdk/schemas/package-info.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/Timers.java | 3 +-
.../org/apache/beam/sdk/state/package-info.java | 3 ++
.../testing/DataflowPortabilityApiUnsupported.java | 3 ++
.../testing/FlattenWithHeterogeneousCoders.java | 2 +
.../java/org/apache/beam/sdk/transforms/DoFn.java | 1 +
.../beam/sdk/transforms/DoFnOutputReceivers.java | 2 +
.../beam/sdk/transforms/DoFnSchemaInformation.java | 2 +
.../sdk/transforms/ExternalTransformBuilder.java | 3 +-
.../beam/sdk/transforms/FlatMapElements.java | 9 ++--
.../apache/beam/sdk/transforms/MapElements.java | 4 +-
.../java/org/apache/beam/sdk/transforms/Watch.java | 3 +-
.../apache/beam/sdk/transforms/WithFailures.java | 3 +-
.../reflect/ByteBuddyDoFnInvokerFactory.java | 2 +-
.../beam/sdk/transforms/reflect/DoFnInvokers.java | 2 +
.../beam/sdk/transforms/reflect/DoFnSignature.java | 2 +
.../sdk/transforms/reflect/DoFnSignatures.java | 2 +
.../sdk/transforms/reflect/OnTimerInvoker.java | 2 +
.../beam/sdk/transforms/reflect/package-info.java | 2 +
.../splittabledofn/ByteKeyRangeTracker.java | 3 ++
.../splittabledofn/HasDefaultTracker.java | 4 ++
.../splittabledofn/OffsetRangeTracker.java | 3 ++
.../splittabledofn/RestrictionTracker.java | 3 ++
.../beam/sdk/transforms/splittabledofn/Sizes.java | 4 ++
.../sdk/transforms/splittabledofn/SplitResult.java | 3 ++
.../transforms/splittabledofn/package-info.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 +-
.../java/org/apache/beam/sdk/util/ApiSurface.java | 2 +
.../org/apache/beam/sdk/util/AppliedCombineFn.java | 2 +
.../util/BufferedElementCountingOutputStream.java | 2 +
.../beam/sdk/util/CombineContextFactory.java | 2 +
.../org/apache/beam/sdk/util/CombineFnUtil.java | 2 +
.../java/org/apache/beam/sdk/util/DoFnInfo.java | 2 +
.../sdk/util/DoFnWithExecutionInformation.java | 2 +
.../apache/beam/sdk/util/ExplicitShardedFile.java | 2 +
.../beam/sdk/util/ExposedByteArrayInputStream.java | 2 +
.../sdk/util/ExposedByteArrayOutputStream.java | 2 +
.../sdk/util/FilePatternMatchingShardedFile.java | 2 +
.../org/apache/beam/sdk/util/IdentityWindowFn.java | 2 +
.../org/apache/beam/sdk/util/MutationDetector.java | 3 ++
.../apache/beam/sdk/util/MutationDetectors.java | 2 +
.../java/org/apache/beam/sdk/util/NameUtils.java | 2 +
.../apache/beam/sdk/util/NumberedShardedFile.java | 2 +
.../java/org/apache/beam/sdk/util/ReleaseInfo.java | 2 +
.../java/org/apache/beam/sdk/util/ShardedFile.java | 2 +
.../beam/sdk/util/ShardingWritableByteChannel.java | 2 +
.../java/org/apache/beam/sdk/util/StreamUtils.java | 2 +
.../java/org/apache/beam/sdk/util/StringUtils.java | 2 +
.../apache/beam/sdk/util/SystemDoFnInternal.java | 2 +
.../apache/beam/sdk/util/UnownedInputStream.java | 2 +
.../apache/beam/sdk/util/UnownedOutputStream.java | 2 +
.../apache/beam/sdk/util/UserCodeException.java | 2 +
.../java/org/apache/beam/sdk/util/Weighted.java | 3 ++
.../org/apache/beam/sdk/util/WeightedValue.java | 3 ++
.../org/apache/beam/sdk/util/WindowTracing.java | 2 +
.../org/apache/beam/sdk/util/WindowedValue.java | 2 +
.../java/org/apache/beam/sdk/util/ZipFiles.java | 2 +
.../common/ElementByteSizeObservableIterable.java | 2 +
.../common/ElementByteSizeObservableIterator.java | 2 +
.../sdk/util/common/ElementByteSizeObserver.java | 2 +
.../apache/beam/sdk/util/common/Reiterable.java | 3 ++
.../apache/beam/sdk/util/common/Reiterator.java | 2 +
.../org/apache/beam/sdk/util/package-info.java | 3 ++
.../beam/sdk/values/ValueInSingleWindow.java | 2 +
.../apache/beam/sdk/values/WindowingStrategy.java | 5 ++-
.../core/client/operator/OutputValues.java | 2 -
.../sdk/extensions/gcp/storage/package-info.java | 4 ++
.../beam/sdk/extensions/jackson/AsJsons.java | 7 ++--
.../beam/sdk/extensions/jackson/ParseJsons.java | 7 ++--
.../beam/sdk/extensions/kryo/package-info.java | 3 ++
.../extensions/protobuf/ProtoSchemaTranslator.java | 3 +-
.../sdk/extensions/sketching/package-info.java | 3 ++
.../sdk/extensions/sql/example/package-info.java | 3 ++
.../meta/provider/datacatalog/package-info.java | 3 ++
.../sql/meta/provider/hcatalog/package-info.java | 3 ++
.../beam/sdk/extensions/sql/jdbc/package-info.java | 3 ++
.../sdk/extensions/sql/zetasql/package-info.java | 3 ++
.../sql/zetasql/translation/package-info.java | 3 ++
.../sdk/extensions/zetasketch/package-info.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 ++
.../beam/sdk/io/aws/s3/S3FileSystemRegistrar.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 ++
.../beam/sdk/io/aws2/dynamodb/DynamoDBIO.java | 3 +-
.../beam/sdk/io/aws2/dynamodb/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 ++
.../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 | 5 +++
.../java/org/apache/beam/sdk/io/amqp/AmqpIO.java | 3 +-
.../org/apache/beam/sdk/io/amqp/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/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/elasticsearch/ElasticsearchIO.java | 3 +-
.../beam/sdk/io/elasticsearch/package-info.java | 4 ++
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 48 +++++++++++-----------
.../beam/sdk/io/gcp/bigquery/BigQueryServices.java | 5 ++-
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 3 +-
.../sdk/io/gcp/bigquery/BigQuerySourceDef.java | 3 +-
.../gcp/bigquery/BigQueryStorageQuerySource.java | 3 +-
.../io/gcp/bigquery/BigQueryStorageSourceBase.java | 3 +-
.../gcp/bigquery/BigQueryStorageStreamSource.java | 5 ++-
.../gcp/bigquery/BigQueryStorageTableSource.java | 3 +-
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 6 +--
.../beam/sdk/io/gcp/bigtable/package-info.java | 4 ++
.../gcp/common/GcpIoPipelineOptionsRegistrar.java | 2 +
.../beam/sdk/io/gcp/datastore/DatastoreIO.java | 3 +-
.../beam/sdk/io/gcp/datastore/package-info.java | 4 ++
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 4 +-
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 9 +---
.../beam/sdk/io/gcp/spanner/package-info.java | 4 ++
.../beam/sdk/io/gcp/testing/BigqueryClient.java | 2 +
.../sdk/io/gcp/testing/FakeBigQueryServices.java | 4 +-
.../sdk/io/gcp/testing/FakeDatasetService.java | 2 +
.../beam/sdk/io/gcp/testing/FakeJobService.java | 4 +-
.../beam/sdk/io/gcp/testing/package-info.java | 3 ++
.../apache/beam/sdk/io/hadoop/package-info.java | 4 ++
.../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 | 4 +-
.../org/apache/beam/sdk/io/hbase/package-info.java | 4 ++
.../apache/beam/sdk/io/hcatalog/HCatalogIO.java | 3 +-
.../apache/beam/sdk/io/hcatalog/package-info.java | 4 ++
.../io/hcatalog/test/EmbeddedMetastoreService.java | 2 +
.../sdk/io/hcatalog/test/HCatalogIOTestUtils.java | 2 +
.../beam/sdk/io/hcatalog/test/package-info.java | 3 ++
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 7 ++--
.../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 ++
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 11 ++---
.../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 +-
.../apache/beam/sdk/io/kinesis/package-info.java | 4 ++
.../java/org/apache/beam/sdk/io/kudu/KuduIO.java | 3 +-
.../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 +-
.../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 ++
.../org/apache/beam/sdk/io/parquet/ParquetIO.java | 3 +-
.../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 ++
.../java/org/apache/beam/sdk/io/solr/SolrIO.java | 3 +-
.../org/apache/beam/sdk/io/solr/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 ++
.../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 ++
263 files changed, 587 insertions(+), 277 deletions(-)
