This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/github_actions/actions/setup-go-4
in repository https://gitbox.apache.org/repos/asf/beam.git
omit f486e1799bf Bump actions/setup-go from 3 to 4
add 907c5110163 Argument fix on Build and Test step (#27684)
add d822fc9a1d3 Bump certifi from 2023.5.7 to 2023.7.22 in
/sdks/python/container/py38 (#27654)
add 21e040c14e4 [AWS] Fix bug in KinesisIOReadTest (closes #27666) (#27686)
add e696414b887 Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#27680)
add 8508e05b35e Add worfklow_dispatch triggers to all new jobs (#27688)
add aa6c8dc6fcd Add MLTransform to __init__ and change input types of
transforms (#27687)
add 505d7c163dd Bump actions/upload-artifact from 2 to 3 (#27677)
add 42393baa989 Update Gradle Wrapper to 7.6.2
add c032a388608 Reconfigure Checkstyle plugin to remove absolute path
inputs
add c754e585c48 Merge pull request #24764: Upgrade gradle to 7.6.2 and
optimize build
add bb6a1730fff Bump certifi from 2023.5.7 to 2023.7.22 in
/sdks/python/container/py310 (#27656)
add f174f2aece6 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#27683)
add 85078169fd0 Bump cloud.google.com/go/bigquery from 1.52.0 to 1.53.0 in
/sdks (#27652)
add b788d09bb37 Add NLP TensorFlow streaming use case (#27659)
add f35a6365e8a explicitly use >=41.0.2 for cryptography (#27608)
add d241eaeeb94 Make all Github Action tests to run at minute 0 of every 6
hours (#27701)
add 2e958499e5d lowercase everything
add 1f4defab42a Merge pull request #27699: Don't make StorageAPI tablerow
names case-sensitive
add d3ea23250b5 Enable FirestoreV1IT to run against a non default host
(#27256)
add 4d712ebfde2 [Documentation] Specify version of HCLS API in
Documentation (#27672)
add cf438d3141c Fetch buffer and add it to pcoll_buffer to avoid element
duplication when buffer is None (#27676)
add 2aabc264cf1 Bump word-wrap (#27557)
add 1c53cc7c1fb Add trigger phrases to workflow names (#27669)
add 27424a403a2 Change how we interrupt in progress runs (#27671)
add af5e43defdd Add instructions on adding new Actions workflows (#27689)
add f50d2098ef6 Bump google.golang.org/api from 0.133.0 to 0.134.0 in
/sdks (#27705)
add dc321f97fa8 Bump certifi from 2023.5.7 to 2023.7.22 in
/sdks/python/container/py39 (#27657)
add 41790473fcd Bump cloud.google.com/go/datastore from 1.12.1 to 1.13.0
in /sdks (#27704)
add bbd49b8891b Add It_Framework PreCommit (#27710)
add 798e0f88aaf Add CassandraResourceManager for managing cassandra
resources in tests. (#27664)
add fa685b0fbf6 moved --dataflowEndpoint to public pipeline option set
add 06ff272bb72 minor linting
add 03da178ecb5 imported Dataflow to DataflowPipelineOptions
add 45781651cb5 added Override decorators
add c6296ba3a17 Merge pull request #27693: Make --dataflowEndpoint a
public option
add 8d4b0bd86d4 [prism] move test functions and tests to internal_test
(#27714)
add 5a54ee6ddd8 [#27558] Update required Go version to 1.20. (#27559)
add c3f16750192 Register create functions to pass on prism. (#27713)
add 66f0592f8b4 Add flags to build multiarch Go SDK containers and fix Go
Dataflow ARM github actions test (#27716)
add 5989a662dc9 populate name map during snapshot restore
add 90f2b3445ff Merge pull request #27638: Populate name map during
snapshot restore
add 548bd4c5344 bump healthcare api version (#27720)
add 1b6d281ac72 Add ElasticsearchResourceManager to manage Elasticsearch
resources in tests. (#27690)
add d966b6b95ae refs: issue-27728, Improve java sdk docs (#27724)
add b1d1fe45fdb Fix ./gradlew build on kafka (#27718)
add bc0b2609a6d Return a useful error when we fail to create a
MonitoringInfo object (#27722)
add 3ac78dd88c4 Update instructions to account for self-hosted runners
(#27717)
add 314750b9db4 Add Jdbc Resource managers to manage various databases in
tests. (#27698)
add 0caf8681d29 Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks
(#27732)
add a4f29348ff7 Bump github.com/aws/aws-sdk-go-v2 from 1.19.0 to 1.19.1 in
/sdks (#27731)
add 9919d5a0dc7 Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#27730)
add 3e144c15d28 Reduce number of connections used by KafkaIO restriction
trackers
add 0b30f1495b7 Merge pull request #27702: Reduce number of connections
used by KafkaIO restriction trackers
add cc410cae08c Github Workflow Replacement for Jenkins Job,
beam_PreCommit_Website_Stage_GCS (Cron, Commit, Phrase) (#27261)
add 7bfead01656 Add missing registrations to integration tests. (#27738)
add 716d49d8c87 Fix error about monitoring_infos closure.
add ffe1c813ad7 Merge pull request #27742 Fix error about monitoring_infos
closure.
add e06dade42e8 Add Kafka Resource managers to manage kafka resources in
tests. (#27739)
add 9b96ff8ce17 Add MongoDB Resource managers to manage mongodb resources
in tests. (#27741)
add 8cc7d3ec6d3 Fix formatting and typo, add gcloud auth. (#27745)
add 0edab70bd53 Fix Neo4j read mapping (#27660)
add b19dbc0be3b Bump hbase client to 2.x (#27746)
add af533fe976c Fix jenkins Go PostCommit runs (#27747)
add 97e5542f163 Update to libraries-bom 26.20.0 (#27725)
add df6964aac62 Bump github.com/fsouza/fake-gcs-server from 1.45.2 to
1.46.0 in /sdks (#27751)
add 05fb24492c6 [Spark DS Runner] Test compatibility against more Spark
versions including latest 3.4.x (closes #27576)
add 881338ed7ff Merge pull request #27597: [Spark DS Runner] Test
compatibility against more Spark versions
add e9c81de7453 Vertex AI Model Handler Private Endpoint Support (#27696)
add 65473ff1501 Bump mypy-protobuf from 3.4.0 to 3.5.0 in /sdks/python
(#27750)
add 991b4b517f7 [prism] Fusion base, reshuffle, cogbk. (#27737)
add 22b30adc848 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#27752)
add b6687993b3b Add the guidance on controlling pipeline dependencies.
(#27749)
add 45cae03570e Inline external action
add 4017a65db9a Revert "Inline external action" accidentally pushed direct
to master
add 36e8254fe31 Standardize workflow files (#27712)
add 1c19bc0dbde Bump actions/setup-go from 3 to 4
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (f486e1799bf)
\
N -- N -- N
refs/heads/dependabot/github_actions/actions/setup-go-4 (1c19bc0dbde)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../gradle-command-self-hosted-action/action.yml | 4 +-
.../test-properties.json | 2 +-
.github/workflows/README.md | 132 ++-
.../workflows/beam_PostCommit_Go_Dataflow_ARM.yml | 41 +-
.../workflows/beam_PreCommit_CommunityMetrics.yml | 53 +-
.github/workflows/beam_PreCommit_Go.yml | 35 +-
.github/workflows/beam_PreCommit_ItFramework.yml | 103 ++
.../beam_PreCommit_Java_Examples_Dataflow.yml | 33 +-
...Commit_Python.yml => beam_PreCommit_Python.yml} | 33 +-
...erBuild.yml => beam_PreCommit_PythonDocker.yml} | 43 +-
.github/workflows/beam_PreCommit_PythonDocs.yml | 20 +-
...tter.yml => beam_PreCommit_PythonFormatter.yml} | 25 +-
...ythonLint.yml => beam_PreCommit_PythonLint.yml} | 28 +-
...rage.yml => beam_PreCommit_Python_Coverage.yml} | 22 +-
...es.yml => beam_PreCommit_Python_Dataframes.yml} | 34 +-
...ples.yml => beam_PreCommit_Python_Examples.yml} | 37 +-
.../beam_PreCommit_Python_Integration.yml | 31 +-
...nners.yml => beam_PreCommit_Python_Runners.yml} | 33 +-
...ms.yml => beam_PreCommit_Python_Transforms.yml} | 36 +-
.github/workflows/beam_PreCommit_RAT.yml | 20 +-
.github/workflows/beam_PreCommit_SQL_Java11.yml | 11 +-
.github/workflows/beam_PreCommit_Typescript.yml | 14 +-
.github/workflows/beam_PreCommit_Website.yml | 22 +-
...te.yml => beam_PreCommit_Website_Stage_GCS.yml} | 75 +-
.github/workflows/beam_PreCommit_Whitespace.yml | 83 +-
.github/workflows/build_wheels.yml | 2 +-
.github/workflows/dask_runner_tests.yml | 2 +-
.github/workflows/go_tests.yml | 2 +-
.github/workflows/java_tests.yml | 2 +-
.github/workflows/local_env_tests.yml | 2 +-
.github/workflows/playground_frontend_test.yml | 2 +-
.github/workflows/python_dependency_tests.yml | 2 +-
.github/workflows/python_tests.yml | 2 +-
.github/workflows/tour_of_beam_backend.yml | 2 +-
.../workflows/tour_of_beam_backend_integration.yml | 2 +-
.github/workflows/tour_of_beam_frontend_test.yml | 2 +-
.github/workflows/typescript_tests.yml | 2 +-
CHANGES.md | 8 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 43 +-
dev-support/docker/Dockerfile | 2 +-
.../beam-ml/nlp_tensorflow_streaming.ipynb | 1110 ++++++++++++++++++++
gradle/wrapper/gradle-wrapper.jar | Bin 59536 -> 61624 bytes
gradle/wrapper/gradle-wrapper.properties | 3 +-
gradlew | 18 +-
gradlew.bat | 15 +-
it/{truthmatchers => cassandra}/build.gradle | 26 +-
.../it/cassandra/CassandraResourceManager.java | 313 ++++++
.../CassandraResourceManagerException.java} | 29 +-
.../cassandra/CassandraResourceManagerUtils.java | 52 +
.../it/cassandra/matchers/CassandraAsserts.java | 74 ++
.../beam/it/cassandra/matchers/package-info.java | 20 +
.../org/apache/beam/it/cassandra/package-info.java | 20 +
.../it/cassandra/CassandraResourceManagerIT.java | 73 ++
.../it/cassandra/CassandraResourceManagerTest.java | 121 +++
it/common/build.gradle | 5 +-
it/elasticsearch/build.gradle | 42 +
.../ElasticsearchResourceManager.java | 287 +++++
.../ElasticsearchResourceManagerException.java} | 29 +-
.../beam/it/elasticsearch/ElasticsearchUtils.java | 85 ++
.../apache/beam/it/elasticsearch/package-info.java | 18 +
.../ElasticsearchResourceManagerIT.java | 72 ++
.../ElasticsearchResourceManagerTest.java | 185 ++++
.../it/elasticsearch/ElasticsearchUtilsTest.java | 109 ++
.../gcp/artifacts/matchers/ArtifactsSubject.java | 3 +
.../it/gcp/artifacts/utils/ParquetTestUtil.java | 3 +-
it/jdbc/build.gradle | 44 +
.../beam/it/jdbc/AbstractJDBCResourceManager.java | 367 +++++++
.../org/apache/beam/it/jdbc/JDBCDriverFactory.java | 41 +
.../apache/beam/it/jdbc/JDBCResourceManager.java | 169 +++
.../it/jdbc/JDBCResourceManagerException.java} | 30 +-
.../beam/it/jdbc/JDBCResourceManagerUtils.java | 115 ++
.../apache/beam/it/jdbc/MSSQLResourceManager.java | 179 ++++
.../apache/beam/it/jdbc/MySQLResourceManager.java | 78 ++
.../apache/beam/it/jdbc/OracleResourceManager.java | 100 ++
.../beam/it/jdbc/PostgresResourceManager.java | 85 ++
.../java/org/apache/beam/it/jdbc/package-info.java | 18 +
.../it/jdbc/AbstractJDBCResourceManagerIT.java | 111 ++
.../it/jdbc/AbstractJDBCResourceManagerTest.java | 287 +++++
.../beam/it/jdbc/JDBCResourceManagerUtilsTest.java | 97 ++
.../beam/it/jdbc/MSSQLResourceManagerTest.java | 81 ++
.../beam/it/jdbc/MySQLResourceManagerTest.java | 59 ++
.../beam/it/jdbc/OracleResourceManagerTest.java | 60 ++
.../beam/it/jdbc/PostgresResourceManagerTest.java | 60 ++
it/{truthmatchers => kafka}/build.gradle | 25 +-
.../apache/beam/it/kafka/KafkaResourceManager.java | 301 ++++++
.../it/kafka/KafkaResourceManagerException.java} | 29 +-
.../beam/it/kafka/KafkaResourceManagerUtils.java | 55 +
.../org/apache/beam/it/kafka/package-info.java | 18 +
.../beam/it/kafka/KafkaResourceManagerTest.java | 178 ++++
.../it/kafka/KafkaResourceManagerUtilsTest.java | 35 +
it/{truthmatchers => mongodb}/build.gradle | 28 +-
.../beam/it/mongodb/MongoDBResourceManager.java | 340 ++++++
.../mongodb/MongoDBResourceManagerException.java} | 29 +-
.../it/mongodb/MongoDBResourceManagerUtils.java | 97 ++
.../mongodb/conditions/MongoDBDocumentsCheck.java | 102 ++
.../beam/it/mongodb/conditions/package-info.java | 18 +
.../beam/it/mongodb/matchers/MongoDBAsserts.java | 64 ++
.../beam/it/mongodb/matchers/package-info.java | 18 +
.../org/apache/beam/it/mongodb/package-info.java | 18 +
.../beam/it/mongodb/MongoDBResourceManagerIT.java | 70 ++
.../it/mongodb/MongoDBResourceManagerTest.java | 280 +++++
.../mongodb/MongoDBResourceManagerUtilsTest.java | 135 +++
it/testcontainers/build.gradle | 6 +-
it/truthmatchers/build.gradle | 5 +-
.../beam/it/truthmatchers/LaunchInfoSubject.java | 3 +
.../beam/it/truthmatchers/ResultSubject.java | 3 +
.../beam/runners/dataflow/DataflowRunner.java | 1 +
.../dataflow/options/DataflowPipelineOptions.java | 20 +
runners/spark/3/build.gradle | 10 +-
sdks/go.mod | 54 +-
sdks/go.sum | 110 +-
sdks/go/container/build.gradle | 7 +-
sdks/go/pkg/beam/core/runtime/exec/translate.go | 11 +-
sdks/go/pkg/beam/create.go | 6 +
sdks/go/pkg/beam/create_test.go | 9 +
.../prism/internal/engine/elementmanager.go | 2 +-
sdks/go/pkg/beam/runners/prism/internal/execute.go | 27 +-
.../beam/runners/prism/internal/execute_test.go | 156 ++-
.../beam/runners/prism/internal/handlerunner.go | 70 +-
.../prism/internal/jobservices/management.go | 38 +-
.../pkg/beam/runners/prism/internal/preprocess.go | 249 ++++-
.../beam/runners/prism/internal/preprocess_test.go | 10 +-
.../beam/runners/prism/internal/separate_test.go | 2 +-
sdks/go/pkg/beam/runners/prism/internal/stage.go | 373 +++----
.../pkg/beam/runners/prism/internal/testdofns.go | 362 -------
.../beam/runners/prism/internal/testdofns_test.go | 346 +++++-
.../runners/prism/internal/unimplemented_test.go | 39 +-
.../pkg/beam/runners/prism/internal/urns/urns.go | 1 +
.../beam/runners/prism/internal/worker/worker.go | 2 +-
.../beam/runners/universal/extworker/extworker.go | 4 +-
.../go/pkg/beam/runners/universal/runnerlib/job.go | 2 +-
sdks/go/run_with_go_version.sh | 2 +-
sdks/go/test/integration/primitives/cogbk.go | 14 +
sdks/go/test/integration/primitives/pardo.go | 1 +
sdks/go/test/run_validatesrunner_tests.sh | 18 +-
.../resources/beam/{ => checkstyle}/checkstyle.xml | 4 +-
.../beam/{ => checkstyle}/suppressions.xml | 0
.../container/license_scripts/dep_urls_java.yaml | 6 +-
.../sdk/io/aws2/kinesis/KinesisIOReadTest.java | 9 +-
sdks/java/io/google-cloud-platform/build.gradle | 4 +
.../io/gcp/bigquery/TableRowToStorageApiProto.java | 6 +-
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 4 +-
.../sdk/io/gcp/firestore/FirestoreOptions.java | 18 +
.../FirestoreStatefulComponentFactory.java | 2 +-
.../apache/beam/sdk/io/gcp/healthcare/DicomIO.java | 2 +-
.../apache/beam/sdk/io/gcp/healthcare/FhirIO.java | 6 +-
.../io/gcp/healthcare/FhirIOPatientEverything.java | 2 +-
.../apache/beam/sdk/io/gcp/healthcare/HL7v2IO.java | 10 +-
.../sdk/io/gcp/healthcare/HealthcareApiClient.java | 4 +-
.../sdk/io/gcp/bigquery/BigQueryIOWriteTest.java | 2 +-
.../sdk/io/gcp/firestore/it/BaseFirestoreIT.java | 26 +-
.../gcp/firestore/it/FirestoreTestingHelper.java | 10 +-
.../sdk/io/gcp/firestore/it/FirestoreV1IT.java | 3 +-
sdks/java/io/hbase/build.gradle | 14 +-
.../org/apache/beam/sdk/io/hbase/HBaseIOTest.java | 11 +-
sdks/java/io/kafka/kafka-integration-test.gradle | 2 +
.../beam/sdk/io/kafka/KafkaUnboundedSource.java | 5 +-
.../beam/sdk/io/kafka/ReadFromKafkaDoFn.java | 61 +-
.../java/org/apache/beam/sdk/io/neo4j/Neo4jIO.java | 30 +-
.../inference/vertex_ai_image_classification.py | 19 +-
.../python/apache_beam/metrics/monitoring_infos.py | 9 +-
sdks/python/apache_beam/ml/__init__.py | 2 +
.../ml/inference/vertex_ai_inference.py | 60 +-
.../ml/inference/vertex_ai_inference_test.py | 18 +-
sdks/python/apache_beam/ml/transforms/tft.py | 11 +-
.../apache-beam-jupyterlab-sidepanel/yarn.lock | 6 +-
.../runners/portability/fn_api_runner/fn_runner.py | 10 +-
.../portability/fn_api_runner/fn_runner_test.py | 9 +
.../apache_beam/runners/worker/operations.py | 9 +-
sdks/python/build-requirements.txt | 2 +-
.../container/py310/base_image_requirements.txt | 2 +-
.../container/py38/base_image_requirements.txt | 2 +-
.../container/py39/base_image_requirements.txt | 2 +-
sdks/python/setup.py | 2 +-
settings.gradle.kts | 5 +
.../content/en/documentation/programming-guide.md | 2 +-
.../sdks/python-pipeline-dependencies.md | 80 +-
.../site/content/en/get-started/quickstart-go.md | 2 +-
178 files changed, 8794 insertions(+), 1242 deletions(-)
create mode 100644 .github/workflows/beam_PreCommit_ItFramework.yml
rename .github/workflows/{job_PreCommit_Python.yml =>
beam_PreCommit_Python.yml} (74%)
rename .github/workflows/{job_PreCommit_Python_DockerBuild.yml =>
beam_PreCommit_PythonDocker.yml} (74%)
rename .github/workflows/{job_PreCommit_PythonAutoformatter.yml =>
beam_PreCommit_PythonFormatter.yml} (78%)
rename .github/workflows/{job_PreCommit_PythonLint.yml =>
beam_PreCommit_PythonLint.yml} (78%)
rename .github/workflows/{job_PreCommit_Python_Coverage.yml =>
beam_PreCommit_Python_Coverage.yml} (81%)
rename .github/workflows/{job_PreCommit_Python_Dataframes.yml =>
beam_PreCommit_Python_Dataframes.yml} (75%)
rename .github/workflows/{job_PreCommit_Python_Examples.yml =>
beam_PreCommit_Python_Examples.yml} (73%)
rename .github/workflows/{job_PreCommit_Python_Runners.yml =>
beam_PreCommit_Python_Runners.yml} (75%)
rename .github/workflows/{job_PreCommit_Python_Transforms.yml =>
beam_PreCommit_Python_Transforms.yml} (75%)
copy .github/workflows/{beam_PreCommit_Website.yml =>
beam_PreCommit_Website_Stage_GCS.yml} (51%)
create mode 100644 examples/notebooks/beam-ml/nlp_tensorflow_streaming.ipynb
copy it/{truthmatchers => cassandra}/build.gradle (55%)
create mode 100644
it/cassandra/src/main/java/org/apache/beam/it/cassandra/CassandraResourceManager.java
copy it/{truthmatchers/build.gradle =>
cassandra/src/main/java/org/apache/beam/it/cassandra/CassandraResourceManagerException.java}
(50%)
create mode 100644
it/cassandra/src/main/java/org/apache/beam/it/cassandra/CassandraResourceManagerUtils.java
create mode 100644
it/cassandra/src/main/java/org/apache/beam/it/cassandra/matchers/CassandraAsserts.java
create mode 100644
it/cassandra/src/main/java/org/apache/beam/it/cassandra/matchers/package-info.java
create mode 100644
it/cassandra/src/main/java/org/apache/beam/it/cassandra/package-info.java
create mode 100644
it/cassandra/src/test/java/org/apache/beam/it/cassandra/CassandraResourceManagerIT.java
create mode 100644
it/cassandra/src/test/java/org/apache/beam/it/cassandra/CassandraResourceManagerTest.java
create mode 100644 it/elasticsearch/build.gradle
create mode 100644
it/elasticsearch/src/main/java/org/apache/beam/it/elasticsearch/ElasticsearchResourceManager.java
copy it/{truthmatchers/build.gradle =>
elasticsearch/src/main/java/org/apache/beam/it/elasticsearch/ElasticsearchResourceManagerException.java}
(50%)
create mode 100644
it/elasticsearch/src/main/java/org/apache/beam/it/elasticsearch/ElasticsearchUtils.java
create mode 100644
it/elasticsearch/src/main/java/org/apache/beam/it/elasticsearch/package-info.java
create mode 100644
it/elasticsearch/src/test/java/org/apache/beam/it/elasticsearch/ElasticsearchResourceManagerIT.java
create mode 100644
it/elasticsearch/src/test/java/org/apache/beam/it/elasticsearch/ElasticsearchResourceManagerTest.java
create mode 100644
it/elasticsearch/src/test/java/org/apache/beam/it/elasticsearch/ElasticsearchUtilsTest.java
create mode 100644 it/jdbc/build.gradle
create mode 100644
it/jdbc/src/main/java/org/apache/beam/it/jdbc/AbstractJDBCResourceManager.java
create mode 100644
it/jdbc/src/main/java/org/apache/beam/it/jdbc/JDBCDriverFactory.java
create mode 100644
it/jdbc/src/main/java/org/apache/beam/it/jdbc/JDBCResourceManager.java
copy it/{truthmatchers/build.gradle =>
jdbc/src/main/java/org/apache/beam/it/jdbc/JDBCResourceManagerException.java}
(50%)
create mode 100644
it/jdbc/src/main/java/org/apache/beam/it/jdbc/JDBCResourceManagerUtils.java
create mode 100644
it/jdbc/src/main/java/org/apache/beam/it/jdbc/MSSQLResourceManager.java
create mode 100644
it/jdbc/src/main/java/org/apache/beam/it/jdbc/MySQLResourceManager.java
create mode 100644
it/jdbc/src/main/java/org/apache/beam/it/jdbc/OracleResourceManager.java
create mode 100644
it/jdbc/src/main/java/org/apache/beam/it/jdbc/PostgresResourceManager.java
create mode 100644
it/jdbc/src/main/java/org/apache/beam/it/jdbc/package-info.java
create mode 100644
it/jdbc/src/test/java/org/apache/beam/it/jdbc/AbstractJDBCResourceManagerIT.java
create mode 100644
it/jdbc/src/test/java/org/apache/beam/it/jdbc/AbstractJDBCResourceManagerTest.java
create mode 100644
it/jdbc/src/test/java/org/apache/beam/it/jdbc/JDBCResourceManagerUtilsTest.java
create mode 100644
it/jdbc/src/test/java/org/apache/beam/it/jdbc/MSSQLResourceManagerTest.java
create mode 100644
it/jdbc/src/test/java/org/apache/beam/it/jdbc/MySQLResourceManagerTest.java
create mode 100644
it/jdbc/src/test/java/org/apache/beam/it/jdbc/OracleResourceManagerTest.java
create mode 100644
it/jdbc/src/test/java/org/apache/beam/it/jdbc/PostgresResourceManagerTest.java
copy it/{truthmatchers => kafka}/build.gradle (59%)
create mode 100644
it/kafka/src/main/java/org/apache/beam/it/kafka/KafkaResourceManager.java
copy it/{truthmatchers/build.gradle =>
kafka/src/main/java/org/apache/beam/it/kafka/KafkaResourceManagerException.java}
(50%)
create mode 100644
it/kafka/src/main/java/org/apache/beam/it/kafka/KafkaResourceManagerUtils.java
create mode 100644
it/kafka/src/main/java/org/apache/beam/it/kafka/package-info.java
create mode 100644
it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaResourceManagerTest.java
create mode 100644
it/kafka/src/test/java/org/apache/beam/it/kafka/KafkaResourceManagerUtilsTest.java
copy it/{truthmatchers => mongodb}/build.gradle (51%)
create mode 100644
it/mongodb/src/main/java/org/apache/beam/it/mongodb/MongoDBResourceManager.java
copy it/{truthmatchers/build.gradle =>
mongodb/src/main/java/org/apache/beam/it/mongodb/MongoDBResourceManagerException.java}
(50%)
create mode 100644
it/mongodb/src/main/java/org/apache/beam/it/mongodb/MongoDBResourceManagerUtils.java
create mode 100644
it/mongodb/src/main/java/org/apache/beam/it/mongodb/conditions/MongoDBDocumentsCheck.java
create mode 100644
it/mongodb/src/main/java/org/apache/beam/it/mongodb/conditions/package-info.java
create mode 100644
it/mongodb/src/main/java/org/apache/beam/it/mongodb/matchers/MongoDBAsserts.java
create mode 100644
it/mongodb/src/main/java/org/apache/beam/it/mongodb/matchers/package-info.java
create mode 100644
it/mongodb/src/main/java/org/apache/beam/it/mongodb/package-info.java
create mode 100644
it/mongodb/src/test/java/org/apache/beam/it/mongodb/MongoDBResourceManagerIT.java
create mode 100644
it/mongodb/src/test/java/org/apache/beam/it/mongodb/MongoDBResourceManagerTest.java
create mode 100644
it/mongodb/src/test/java/org/apache/beam/it/mongodb/MongoDBResourceManagerUtilsTest.java
delete mode 100644 sdks/go/pkg/beam/runners/prism/internal/testdofns.go
rename sdks/java/build-tools/src/main/resources/beam/{ =>
checkstyle}/checkstyle.xml (99%)
rename sdks/java/build-tools/src/main/resources/beam/{ =>
checkstyle}/suppressions.xml (100%)
