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 1019ef3 Prepare a website update for 2.23.0 (#12212)
add a443fdd Refactor Beam SQL QueryPlanner instantiation to be more type
safe and robust
add 8084d1b Move individual spotbug suppressions out of
spotbugs-filter.xml and remove some global suppressions
add 12631cb [BEAM-10575] Fix rawtypes in FileSystemRegistrar and
implementations
add 45d1a5c [BEAM-10556] Eliminate remaining trivial rawtypes in
sdks/java/io/hadoop-file-system
add eb20f3a [BEAM-10577] Eliminate remaining trivial rawtypes in
sdks/java/io/azure
add ab29122 [BEAM-10575] Eliminate rawtypes from GCP IOs and enable
-Wrawtypes
new c2eb01d Merge pull request #12376: [BEAM-10575] Eliminate legacy
rawtypes from GCP IOs and some others; enable -Wrawtypes -Werror
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:
.../apache/beam/examples/snippets/Snippets.java | 2 +-
.../beam/examples/complete/AutoCompleteTest.java | 2 +-
.../complete/game/StatefulTeamScoreTest.java | 1 -
.../org/apache/beam/runners/core/DoFnRunner.java | 8 +-
.../apache/beam/runners/core/PaneInfoTracker.java | 3 +
.../org/apache/beam/runners/core/StateMerging.java | 2 +
.../apache/beam/runners/core/SystemReduceFn.java | 2 +
.../apache/beam/runners/core/WatermarkHold.java | 6 +
.../direct/ExecutorServiceParallelExecutor.java | 13 +
.../runners/direct/ParDoMultiOverrideFactory.java | 4 +
.../beam/runners/flink/metrics/FileReporter.java | 3 +
.../beam/runners/dataflow/TestDataflowRunner.java | 2 +
.../runners/dataflow/util/OutputReference.java | 2 +
.../beam/runners/dataflow/worker/graph/Nodes.java | 4 +-
.../JulHandlerPrintStreamAdapterFactory.java | 15 +-
.../jobsubmission/PortablePipelineJarCreator.java | 4 +-
.../beam/runners/spark/metrics/sink/CsvSink.java | 3 +
.../runners/spark/metrics/sink/GraphiteSink.java | 3 +
.../src/main/resources/beam/spotbugs-filter.xml | 426 ++-------------------
.../java/org/apache/beam/sdk/coders/AvroCoder.java | 5 +
.../apache/beam/sdk/coders/SerializableCoder.java | 3 +
.../sdk/expansion/ExternalTransformRegistrar.java | 2 +-
.../apache/beam/sdk/io/ClassLoaderFileSystem.java | 2 +-
.../apache/beam/sdk/io/FileSystemRegistrar.java | 2 +-
.../org/apache/beam/sdk/io/GenerateSequence.java | 2 +-
.../beam/sdk/io/LocalFileSystemRegistrar.java | 2 +-
.../beam/sdk/options/ProxyInvocationHandler.java | 10 +
.../java/org/apache/beam/sdk/testing/PAssert.java | 2 +
.../beam/sdk/testing/SerializableMatchers.java | 2 +
.../apache/beam/sdk/testing/WindowSupplier.java | 3 +
.../java/org/apache/beam/sdk/transforms/Mean.java | 4 +
.../org/apache/beam/sdk/util/CombineFnUtil.java | 4 +
.../sdk/util/ExposedByteArrayOutputStream.java | 2 +
.../beam/sdk/io/LocalFileSystemRegistrarTest.java | 3 +-
.../sdk/expansion/service/ExpansionService.java | 14 +-
.../google-cloud-platform-core/build.gradle | 1 -
.../gcp/storage/GcsFileSystemRegistrar.java | 2 +-
.../beam/sdk/extensions/gcp/util/GcsUtil.java | 3 +
.../gcp/storage/GcsFileSystemRegistrarTest.java | 3 +-
.../expansion/ExternalSqlTransformRegistrar.java | 2 +-
.../beam/sdk/extensions/sql/jdbc/BeamSqlLine.java | 5 +-
.../provider/bigquery/BigQueryIOPushDownIT.java | 3 +-
.../beam/sdk/extensions/sql/impl/BeamSqlEnv.java | 31 +-
.../extensions/sql/impl/CalciteQueryPlanner.java | 17 +-
.../beam/sdk/extensions/sql/impl/QueryPlanner.java | 6 +
.../extensions/sql/impl/planner/BeamRuleSets.java | 19 +-
.../sql/impl/rule/IOPushDownRuleTest.java | 3 +-
.../sql/impl/rule/JoinReorderingTest.java | 4 +-
...tTableProviderWithFilterAndProjectPushDown.java | 3 +-
.../test/TestTableProviderWithFilterPushDown.java | 3 +-
.../test/TestTableProviderWithProjectPushDown.java | 3 +-
.../sql/zetasql/ZetaSQLQueryPlanner.java | 31 +-
.../sql/zetasql/ZetaSQLPushDownTest.java | 3 +-
.../extensions/sql/zetasql/ZetaSqlTestBase.java | 3 +-
.../beam/sdk/io/aws/s3/S3FileSystemRegistrar.java | 2 +-
sdks/java/io/azure/build.gradle | 3 +-
.../AzureBlobStoreFileSystemRegistrar.java | 2 +-
.../sdk/io/azure/blobstore/AzfsResourceIdTest.java | 2 +-
sdks/java/io/google-cloud-platform/build.gradle | 1 -
.../sdk/io/gcp/bigquery/BigQueryServicesImpl.java | 6 +-
.../gcp/bigquery/BigQueryStorageStreamSource.java | 2 +-
.../beam/sdk/io/gcp/bigquery/BigQueryUtils.java | 11 +-
.../sdk/io/gcp/bigquery/TableRowInfoCoder.java | 4 +-
.../beam/sdk/io/gcp/bigquery/TagWithUniqueIds.java | 5 +-
.../beam/sdk/io/gcp/bigquery/WriteTables.java | 4 +-
.../io/gcp/healthcare/HealthcareIOErrorCoder.java | 2 +-
.../beam/sdk/io/gcp/pubsub/ExternalRead.java | 2 +-
.../beam/sdk/io/gcp/pubsub/ExternalWrite.java | 2 +-
.../beam/sdk/io/gcp/spanner/SpannerAccessor.java | 4 +-
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 6 +-
.../sdk/io/gcp/testing/FakeBigQueryServices.java | 2 +-
.../sdk/io/gcp/bigquery/BigQueryIOReadTest.java | 6 +-
.../gcp/bigquery/BigQueryIOStorageQueryTest.java | 2 +-
.../io/gcp/bigquery/BigQueryIOStorageReadTest.java | 2 +-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 4 +-
.../sdk/io/gcp/pubsub/PubsubIOExternalTest.java | 2 +-
.../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 31 +-
sdks/java/io/hadoop-file-system/build.gradle | 1 -
.../sdk/io/hdfs/HadoopFileSystemRegistrar.java | 4 +-
.../sdk/io/hdfs/HadoopFileSystemModuleTest.java | 6 +-
.../sdk/io/hdfs/HadoopFileSystemOptionsTest.java | 4 +-
.../sdk/io/hdfs/HadoopFileSystemRegistrarTest.java | 2 +-
.../java/org/apache/beam/sdk/io/jdbc/JdbcIO.java | 5 +
.../beam/sdk/io/jdbc/JdbcReadRowsRegistrar.java | 2 +-
.../beam/sdk/io/jdbc/JdbcWriteRegistrar.java | 2 +-
.../java/org/apache/beam/sdk/io/jms/JmsRecord.java | 10 +
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 20 +-
.../testing/expansion/TestExpansionService.java | 4 +-
88 files changed, 346 insertions(+), 533 deletions(-)
