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 2020/07/30 02:22:59 UTC
[beam] 01/01: Merge pull request #12376: [BEAM-10575] Eliminate
legacy rawtypes from GCP IOs and some others; enable -Wrawtypes -Werror
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 c2eb01df5098a8c4a5422dc7e5e5c890edc58bc7
Merge: 1019ef3 ab29122
Author: Kenn Knowles <ke...@apache.org>
AuthorDate: Wed Jul 29 19:22:30 2020 -0700
Merge pull request #12376: [BEAM-10575] Eliminate legacy rawtypes from GCP IOs and some others; enable -Wrawtypes -Werror
.../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(-)