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:58 UTC
[beam] branch master updated (1019ef3 -> c2eb01d)
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(-)
[beam] 01/01: Merge pull request #12376: [BEAM-10575] Eliminate
legacy rawtypes from GCP IOs and some others; enable -Wrawtypes -Werror
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 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(-)