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 aca9099acca969dc217ab183782e5270347cd354 Merge: 68d6c8e 91104aa Author: Kenn Knowles <[email protected]> AuthorDate: Sat Oct 24 15:13:33 2020 -0700 Merge pull request #13192: [BEAM-10402] Move @Nullable annotations adjacent to the type they annotate .../core/construction/ExternalTranslation.java | 3 +- .../core/construction/PTransformMatchersTest.java | 3 +- .../apache/beam/runners/core/SideInputHandler.java | 3 +- .../core/metrics/ExecutionStateTracker.java | 2 +- .../beam/runners/direct/ReadEvaluatorFactory.java | 3 +- .../runners/direct/TestStreamEvaluatorFactory.java | 3 +- .../direct/WriteWithShardingFactoryTest.java | 3 +- .../functions/FlinkSideInputReader.java | 3 +- .../wrappers/streaming/DoFnOperator.java | 6 ++-- .../runners/flink/FlinkTransformOverridesTest.java | 3 +- .../wrappers/streaming/DoFnOperatorTest.java | 3 +- .../wrappers/streaming/StreamRecordStripper.java | 3 +- .../beam/runners/dataflow/DataflowPipelineJob.java | 8 +++--- .../beam/runners/dataflow/TestDataflowRunner.java | 2 +- .../runners/dataflow/util/DataflowTemplateJob.java | 2 +- .../beam/runners/dataflow/DataflowRunnerTest.java | 3 +- .../dataflow/worker/BatchModeExecutionContext.java | 6 ++-- .../worker/DataflowPortabilityPCollectionView.java | 3 +- ...FetchAndFilterStreamingSideInputsOperation.java | 3 +- .../runners/dataflow/worker/InMemoryReader.java | 3 +- .../worker/LazilyInitializedSideInputReader.java | 3 +- .../dataflow/worker/SdkHarnessRegistries.java | 18 ++++-------- .../runners/dataflow/worker/SimpleParDoFn.java | 2 +- .../worker/StreamingModeExecutionContext.java | 3 +- .../dataflow/worker/WorkItemStatusClient.java | 2 +- .../dataflow/worker/WorkerCustomSources.java | 3 +- .../worker/fn/control/BeamFnMapTaskExecutor.java | 27 ++++++------------ .../worker/DataflowOperationContextTest.java | 3 +- .../dataflow/worker/TestOperationContext.java | 3 +- .../fn/control/BeamFnMapTaskExecutorTest.java | 16 ++++------- .../DataflowSideInputHandlerFactoryTest.java | 3 +- .../RegisterAndProcessBundleOperationTest.java | 3 +- .../beam/runners/samza/runtime/KeyedInternals.java | 6 ++-- .../spark/stateful/SparkTimerInternals.java | 6 ++-- .../batch/functions/SparkSideInputReader.java | 3 +- .../translation/utils/CachedSideInputReader.java | 3 +- .../runners/spark/util/CachedSideInputReader.java | 3 +- .../runners/spark/util/SparkSideInputReader.java | 3 +- .../twister2/utils/Twister2SideInputReader.java | 3 +- .../main/java/org/apache/beam/sdk/io/AvroIO.java | 3 +- .../apache/beam/sdk/io/ClassLoaderFileSystem.java | 3 +- .../org/apache/beam/sdk/io/CompressedSource.java | 4 +-- .../beam/sdk/io/DynamicFileDestinations.java | 3 +- .../main/java/org/apache/beam/sdk/io/FileIO.java | 6 ++-- .../org/apache/beam/sdk/io/LocalResourceId.java | 2 +- .../apache/beam/sdk/schemas/AutoValueSchema.java | 3 +- .../apache/beam/sdk/schemas/SchemaRegistry.java | 11 ++++---- .../java/org/apache/beam/sdk/state/StateSpecs.java | 2 +- .../beam/sdk/transforms/display/DisplayData.java | 4 +-- .../beam/sdk/transforms/reflect/DoFnSignature.java | 33 ++++++++-------------- .../apache/beam/sdk/values/PCollectionView.java | 2 +- .../main/java/org/apache/beam/sdk/values/Row.java | 6 ++-- .../org/apache/beam/sdk/values/RowWithGetters.java | 3 +- .../org/apache/beam/sdk/values/RowWithStorage.java | 3 +- .../org/apache/beam/sdk/io/TextIOWriteTest.java | 6 ++-- .../apache/beam/sdk/schemas/utils/TestPOJOs.java | 2 +- .../org/apache/beam/sdk/transforms/WatchTest.java | 6 ++-- .../extensions/protobuf/ProtoMessageSchema.java | 3 +- .../meta/provider/hcatalog/DatabaseProvider.java | 3 +- .../sql/impl/rel/BeamEnumerableConverter.java | 2 +- .../sql/meta/provider/FullNameTableProvider.java | 3 +- .../bigquery/BigQueryTestTableProvider.java | 3 +- .../beam/fn/harness/state/FnApiStateAccessor.java | 3 +- .../apache/beam/sdk/io/aws/s3/S3ResourceId.java | 3 +- .../sdk/io/azure/blobstore/AzfsResourceId.java | 3 +- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 9 ++---- .../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 3 +- .../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 3 +- .../sdk/io/gcp/pubsub/PubsubUnboundedSource.java | 3 +- .../beam/sdk/io/gcp/spanner/SpannerConfig.java | 3 +- .../BigQueryTimePartitioningClusteringIT.java | 3 +- .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 25 ++++++---------- .../sdk/io/kinesis/KinesisTransformRegistrar.java | 20 ++++++------- .../org/apache/beam/sdk/io/splunk/SplunkEvent.java | 3 +- .../apache/beam/sdk/nexmark/NexmarkOptions.java | 12 ++++---- .../org/apache/beam/sdk/nexmark/model/Event.java | 6 ++-- 76 files changed, 147 insertions(+), 249 deletions(-)
