You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jo...@apache.org on 2023/07/24 14:32:29 UTC
[beam] branch master updated (cbe2e0f5ad5 -> d639cc8e625)
This is an automated email from the ASF dual-hosted git repository.
johncasey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from cbe2e0f5ad5 Merge pull request #27590: Properly translate TimestampedValueCoder on runnerv1
add d639cc8e625 Add Integration/Load test Utilities. (#27579)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 3 +
it/OWNERS | 5 +
it/common/build.gradle | 48 ++
.../apache/beam/it/common/PipelineLauncher.java | 437 +++++++++++++++++
.../apache/beam/it/common/PipelineOperator.java | 313 ++++++++++++
.../org/apache/beam/it/common/ResourceManager.java | 25 +
.../org/apache/beam/it/common/TestProperties.java | 293 +++++++++++
.../apache/beam/it/common/logging/LogStrings.java | 64 +++
.../beam/it/common/logging/package-info.java | 20 +
.../org/apache/beam/it/common/package-info.java | 20 +
.../beam/it/common/utils/ExceptionUtils.java | 43 ++
.../beam/it/common/utils/IORedirectUtil.java | 52 ++
.../apache/beam/it/common/utils/PipelineUtils.java | 117 +++++
.../beam/it/common/utils/ResourceManagerUtils.java | 208 ++++++++
.../org/apache/beam/it/common/utils/RetryUtil.java | 53 ++
.../apache/beam/it/common/utils/package-info.java | 20 +
.../beam/it/common/PipelineOperatorTest.java | 202 ++++++++
.../apache/beam/it/common/TestPropertiesTest.java | 92 ++++
.../beam/it/common/utils/ExceptionUtilsTest.java | 66 +++
.../beam/it/common/utils/PipelineUtilsTest.java | 48 ++
.../it/common/utils/ResourceManagerUtilsTest.java | 195 ++++++++
it/conditions/build.gradle | 31 ++
.../apache/beam/it/conditions/ConditionCheck.java | 85 ++++
.../apache/beam/it/conditions/package-info.java | 20 +
it/google-cloud-platform/build.gradle | 74 +++
.../java/org/apache/beam/it/gcp/GCPBaseIT.java | 46 ++
.../beam/it/gcp/GoogleCloudIntegrationTest.java | 28 ++
.../org/apache/beam/it/gcp/IOLoadTestBase.java | 104 ++++
.../java/org/apache/beam/it/gcp/LoadTestBase.java | 512 +++++++++++++++++++
.../org/apache/beam/it/gcp/artifacts/Artifact.java | 41 ++
.../beam/it/gcp/artifacts/ArtifactClient.java | 122 +++++
.../apache/beam/it/gcp/artifacts/GcsArtifact.java | 44 ++
.../it/gcp/artifacts/matchers/ArtifactAsserts.java | 63 +++
.../gcp/artifacts/matchers/ArtifactsSubject.java | 168 +++++++
.../it/gcp/artifacts/matchers/package-info.java | 20 +
.../apache/beam/it/gcp/artifacts/package-info.java | 20 +
.../beam/it/gcp/artifacts/utils/ArtifactUtils.java | 80 +++
.../beam/it/gcp/artifacts/utils/AvroTestUtil.java | 78 +++
.../beam/it/gcp/artifacts/utils/JsonTestUtil.java | 89 ++++
.../it/gcp/artifacts/utils/ParquetTestUtil.java | 134 +++++
.../beam/it/gcp/artifacts/utils/package-info.java | 20 +
.../it/gcp/bigquery/BigQueryResourceManager.java | 504 +++++++++++++++++++
.../bigquery/BigQueryResourceManagerException.java | 26 +
.../gcp/bigquery/BigQueryResourceManagerUtils.java | 93 ++++
.../gcp/bigquery/conditions/BigQueryRowsCheck.java | 97 ++++
.../it/gcp/bigquery/conditions/package-info.java | 20 +
.../it/gcp/bigquery/matchers/BigQueryAsserts.java | 109 +++++
.../it/gcp/bigquery/matchers/package-info.java | 20 +
.../apache/beam/it/gcp/bigquery/package-info.java | 20 +
.../it/gcp/bigquery/utils/BigQueryTestUtil.java | 119 +++++
.../beam/it/gcp/bigquery/utils/package-info.java | 20 +
.../it/gcp/bigtable/BigtableResourceManager.java | 540 +++++++++++++++++++++
.../BigtableResourceManagerClientFactory.java | 90 ++++
.../bigtable/BigtableResourceManagerCluster.java | 65 +++
.../bigtable/BigtableResourceManagerException.java | 30 ++
.../gcp/bigtable/BigtableResourceManagerUtils.java | 127 +++++
.../beam/it/gcp/bigtable/BigtableTableSpec.java | 64 +++
.../it/gcp/bigtable/matchers/BigtableAsserts.java | 70 +++
.../it/gcp/bigtable/matchers/package-info.java | 20 +
.../apache/beam/it/gcp/bigtable/package-info.java | 20 +
.../it/gcp/dataflow/AbstractPipelineLauncher.java | 320 ++++++++++++
.../it/gcp/dataflow/ClassicTemplateClient.java | 130 +++++
.../it/gcp/dataflow/DefaultPipelineLauncher.java | 480 ++++++++++++++++++
.../beam/it/gcp/dataflow/DirectRunnerClient.java | 262 ++++++++++
.../beam/it/gcp/dataflow/FlexTemplateClient.java | 137 ++++++
.../apache/beam/it/gcp/dataflow/package-info.java | 20 +
.../beam/it/gcp/datagenerator/DataGenerator.java | 273 +++++++++++
.../beam/it/gcp/datagenerator/package-info.java | 19 +
.../it/gcp/datastore/DatastoreResourceManager.java | 172 +++++++
.../DatastoreResourceManagerException.java | 26 +
.../beam/it/gcp/datastore/DatastoreUtils.java | 51 ++
.../gcp/datastore/matchers/DatastoreAsserts.java | 70 +++
.../it/gcp/datastore/matchers/package-info.java | 19 +
.../apache/beam/it/gcp/datastore/package-info.java | 20 +
.../gcp/datastream/DatastreamResourceManager.java | 509 +++++++++++++++++++
.../DatastreamResourceManagerException.java | 30 ++
.../apache/beam/it/gcp/datastream/JDBCSource.java | 92 ++++
.../apache/beam/it/gcp/datastream/MySQLSource.java | 80 +++
.../beam/it/gcp/datastream/OracleSource.java | 81 ++++
.../beam/it/gcp/datastream/PostgresqlSource.java | 110 +++++
.../beam/it/gcp/datastream/package-info.java | 20 +
.../apache/beam/it/gcp/dlp/DlpResourceManager.java | 164 +++++++
.../org/apache/beam/it/gcp/dlp/package-info.java | 22 +
.../apache/beam/it/gcp/kms/KMSClientFactory.java | 52 ++
.../apache/beam/it/gcp/kms/KMSResourceManager.java | 274 +++++++++++
.../it/gcp/kms/KMSResourceManagerException.java | 26 +
.../org/apache/beam/it/gcp/kms/package-info.java | 20 +
.../beam/it/gcp/monitoring/MonitoringClient.java | 470 ++++++++++++++++++
.../beam/it/gcp/monitoring/package-info.java | 20 +
.../java/org/apache/beam/it/gcp/package-info.java | 20 +
.../beam/it/gcp/pubsub/PubsubPublisherFactory.java | 47 ++
.../beam/it/gcp/pubsub/PubsubResourceManager.java | 384 +++++++++++++++
.../gcp/pubsub/PubsubResourceManagerException.java | 26 +
.../org/apache/beam/it/gcp/pubsub/PubsubUtils.java | 115 +++++
.../gcp/pubsub/conditions/PubsubMessagesCheck.java | 118 +++++
.../it/gcp/pubsub/conditions/package-info.java | 20 +
.../apache/beam/it/gcp/pubsub/package-info.java | 20 +
.../gcp/pubsublite/PubsubliteResourceManager.java | 215 ++++++++
.../beam/it/gcp/pubsublite/package-info.java | 20 +
.../it/gcp/spanner/SpannerResourceManager.java | 387 +++++++++++++++
.../spanner/SpannerResourceManagerException.java | 26 +
.../it/gcp/spanner/matchers/SpannerAsserts.java | 103 ++++
.../beam/it/gcp/spanner/matchers/package-info.java | 20 +
.../apache/beam/it/gcp/spanner/package-info.java | 20 +
.../spanner/utils/SpannerResourceManagerUtils.java | 95 ++++
.../beam/it/gcp/spanner/utils/package-info.java | 20 +
.../beam/it/gcp/storage/GcsResourceManager.java | 307 ++++++++++++
.../apache/beam/it/gcp/storage/package-info.java | 20 +
.../java/org/apache/beam/it/gcp/WordCountIT.java | 86 ++++
.../beam/it/gcp/artifacts/GcsArtifactTest.java | 66 +++
.../it/gcp/artifacts/utils/ArtifactUtilsTest.java | 70 +++
.../apache/beam/it/gcp/bigquery/BigQueryIOLT.java | 457 +++++++++++++++++
.../gcp/bigquery/BigQueryResourceManagerTest.java | 291 +++++++++++
.../bigquery/BigQueryResourceManagerUtilsTest.java | 58 +++
.../apache/beam/it/gcp/bigtable/BigTableIOLT.java | 275 +++++++++++
.../BigtableResourceManagerClientFactoryTest.java | 97 ++++
.../BigtableResourceManagerClusterTest.java | 47 ++
.../it/gcp/bigtable/BigtableResourceManagerIT.java | 81 ++++
.../gcp/bigtable/BigtableResourceManagerTest.java | 454 +++++++++++++++++
.../bigtable/BigtableResourceManagerUtilsTest.java | 85 ++++
.../gcp/dataflow/AbstractPipelineLauncherTest.java | 170 +++++++
.../it/gcp/dataflow/ClassicTemplateClientTest.java | 179 +++++++
.../gcp/dataflow/DefaultPipelineLauncherTest.java | 86 ++++
.../it/gcp/dataflow/FlexTemplateClientTest.java | 184 +++++++
.../gcp/datastore/DatastoreResourceManagerIT.java | 90 ++++
.../datastore/DatastoreResourceManagerTest.java | 125 +++++
.../datastream/DatastreamResourceManagerTest.java | 297 ++++++++++++
.../beam/it/gcp/kms/KMSResourceManagerIT.java | 64 +++
.../beam/it/gcp/kms/KMSResourceManagerTest.java | 202 ++++++++
.../it/gcp/pubsub/PubsubResourceManagerTest.java | 269 ++++++++++
.../apache/beam/it/gcp/pubsub/PubsubUtilsTest.java | 80 +++
.../it/gcp/spanner/SpannerResourceManagerTest.java | 531 ++++++++++++++++++++
.../utils/SpannerResourceManagerUtilsTest.java | 127 +++++
.../apache/beam/it/gcp/storage/FileBasedIOLT.java | 258 ++++++++++
.../it/gcp/storage/GcsResourceManagerTest.java | 376 ++++++++++++++
.../src/test/resources/test-artifact.txt | 1 +
it/truthmatchers/build.gradle | 35 ++
.../beam/it/truthmatchers/LaunchInfoSubject.java | 59 +++
.../beam/it/truthmatchers/ListAccumulator.java | 61 +++
.../beam/it/truthmatchers/PipelineAsserts.java | 93 ++++
.../beam/it/truthmatchers/RecordsSubject.java | 234 +++++++++
.../beam/it/truthmatchers/ResultSubject.java | 71 +++
.../apache/beam/it/truthmatchers/package-info.java | 20 +
.../src/main/resources/beam/checkstyle.xml | 2 +-
.../src/main/resources/beam/suppressions.xml | 12 +
settings.gradle.kts | 5 +
146 files changed, 17806 insertions(+), 1 deletion(-)
create mode 100644 it/OWNERS
create mode 100644 it/common/build.gradle
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/PipelineLauncher.java
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/PipelineOperator.java
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/ResourceManager.java
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/TestProperties.java
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/logging/LogStrings.java
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/logging/package-info.java
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/package-info.java
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/utils/ExceptionUtils.java
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/utils/IORedirectUtil.java
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/utils/PipelineUtils.java
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/utils/ResourceManagerUtils.java
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/utils/RetryUtil.java
create mode 100644 it/common/src/main/java/org/apache/beam/it/common/utils/package-info.java
create mode 100644 it/common/src/test/java/org/apache/beam/it/common/PipelineOperatorTest.java
create mode 100644 it/common/src/test/java/org/apache/beam/it/common/TestPropertiesTest.java
create mode 100644 it/common/src/test/java/org/apache/beam/it/common/utils/ExceptionUtilsTest.java
create mode 100644 it/common/src/test/java/org/apache/beam/it/common/utils/PipelineUtilsTest.java
create mode 100644 it/common/src/test/java/org/apache/beam/it/common/utils/ResourceManagerUtilsTest.java
create mode 100644 it/conditions/build.gradle
create mode 100644 it/conditions/src/main/java/org/apache/beam/it/conditions/ConditionCheck.java
create mode 100644 it/conditions/src/main/java/org/apache/beam/it/conditions/package-info.java
create mode 100644 it/google-cloud-platform/build.gradle
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/GCPBaseIT.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/GoogleCloudIntegrationTest.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/IOLoadTestBase.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/LoadTestBase.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/Artifact.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/ArtifactClient.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/GcsArtifact.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/matchers/ArtifactAsserts.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/matchers/ArtifactsSubject.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/matchers/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/utils/ArtifactUtils.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/utils/AvroTestUtil.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/utils/JsonTestUtil.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/utils/ParquetTestUtil.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/artifacts/utils/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManager.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManagerException.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManagerUtils.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/conditions/BigQueryRowsCheck.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/conditions/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/matchers/BigQueryAsserts.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/matchers/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/utils/BigQueryTestUtil.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigquery/utils/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManager.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerClientFactory.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerCluster.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerException.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerUtils.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigtable/BigtableTableSpec.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigtable/matchers/BigtableAsserts.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigtable/matchers/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/bigtable/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/AbstractPipelineLauncher.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/ClassicTemplateClient.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/DefaultPipelineLauncher.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/DirectRunnerClient.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/FlexTemplateClient.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dataflow/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datagenerator/DataGenerator.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datagenerator/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastore/DatastoreResourceManager.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastore/DatastoreResourceManagerException.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastore/DatastoreUtils.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastore/matchers/DatastoreAsserts.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastore/matchers/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastore/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastream/DatastreamResourceManager.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastream/DatastreamResourceManagerException.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastream/JDBCSource.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastream/MySQLSource.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastream/OracleSource.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastream/PostgresqlSource.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/datastream/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dlp/DlpResourceManager.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/dlp/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/kms/KMSClientFactory.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/kms/KMSResourceManager.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/kms/KMSResourceManagerException.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/kms/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/monitoring/MonitoringClient.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/monitoring/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubPublisherFactory.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubResourceManager.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubResourceManagerException.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/PubsubUtils.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/conditions/PubsubMessagesCheck.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/conditions/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsub/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsublite/PubsubliteResourceManager.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/pubsublite/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerResourceManager.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/SpannerResourceManagerException.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/matchers/SpannerAsserts.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/matchers/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/utils/SpannerResourceManagerUtils.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/spanner/utils/package-info.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/storage/GcsResourceManager.java
create mode 100644 it/google-cloud-platform/src/main/java/org/apache/beam/it/gcp/storage/package-info.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/WordCountIT.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/artifacts/GcsArtifactTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/artifacts/utils/ArtifactUtilsTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryIOLT.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManagerTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigquery/BigQueryResourceManagerUtilsTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigTableIOLT.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerClientFactoryTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerClusterTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerIT.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/bigtable/BigtableResourceManagerUtilsTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/dataflow/AbstractPipelineLauncherTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/dataflow/ClassicTemplateClientTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/dataflow/DefaultPipelineLauncherTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/dataflow/FlexTemplateClientTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/datastore/DatastoreResourceManagerIT.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/datastore/DatastoreResourceManagerTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/datastream/DatastreamResourceManagerTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/kms/KMSResourceManagerIT.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/kms/KMSResourceManagerTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/pubsub/PubsubResourceManagerTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/pubsub/PubsubUtilsTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/SpannerResourceManagerTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/spanner/utils/SpannerResourceManagerUtilsTest.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/storage/FileBasedIOLT.java
create mode 100644 it/google-cloud-platform/src/test/java/org/apache/beam/it/gcp/storage/GcsResourceManagerTest.java
create mode 100644 it/google-cloud-platform/src/test/resources/test-artifact.txt
create mode 100644 it/truthmatchers/build.gradle
create mode 100644 it/truthmatchers/src/main/java/org/apache/beam/it/truthmatchers/LaunchInfoSubject.java
create mode 100644 it/truthmatchers/src/main/java/org/apache/beam/it/truthmatchers/ListAccumulator.java
create mode 100644 it/truthmatchers/src/main/java/org/apache/beam/it/truthmatchers/PipelineAsserts.java
create mode 100644 it/truthmatchers/src/main/java/org/apache/beam/it/truthmatchers/RecordsSubject.java
create mode 100644 it/truthmatchers/src/main/java/org/apache/beam/it/truthmatchers/ResultSubject.java
create mode 100644 it/truthmatchers/src/main/java/org/apache/beam/it/truthmatchers/package-info.java