Update IOs to work with Lineage based on BoundedTrie
显示
- sdks/java/core/src/main/java/org/apache/beam/sdk/metrics/Lineage.java 55 个添加, 64 个删除...re/src/main/java/org/apache/beam/sdk/metrics/Lineage.java
- sdks/java/core/src/test/java/org/apache/beam/sdk/metrics/LineageTest.java 16 个添加, 1 个删除...rc/test/java/org/apache/beam/sdk/metrics/LineageTest.java
- sdks/java/extensions/google-cloud-platform-core/src/main/java/org/apache/beam/sdk/extensions/gcp/storage/GcsFileSystem.java 1 个添加, 1 个删除...apache/beam/sdk/extensions/gcp/storage/GcsFileSystem.java
- sdks/java/extensions/google-cloud-platform-core/src/test/java/org/apache/beam/sdk/extensions/gcp/storage/GcsFileSystemTest.java 1 个添加, 1 个删除...he/beam/sdk/extensions/gcp/storage/GcsFileSystemTest.java
- sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/s3/S3FileSystem.java 1 个添加, 1 个删除...ain/java/org/apache/beam/sdk/io/aws2/s3/S3FileSystem.java
- sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/s3/S3FileSystemTest.java 1 个添加, 1 个删除...java/org/apache/beam/sdk/io/aws2/s3/S3FileSystemTest.java
- sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystem.java 3 个添加, 2 个删除...beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystem.java
- sdks/java/io/azure/src/test/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystemTest.java 1 个添加, 1 个删除.../sdk/io/azure/blobstore/AzureBlobStoreFileSystemTest.java
- sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PreparePubsubWriteDoFn.java 5 个添加, 1 个删除...apache/beam/sdk/io/gcp/pubsub/PreparePubsubWriteDoFn.java
- sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java 3 个添加, 2 个删除...main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
- sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadIT.java 1 个添加, 4 个删除...a/org/apache/beam/sdk/io/gcp/bigtable/BigtableReadIT.java
- sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteIT.java 1 个添加, 3 个删除.../org/apache/beam/sdk/io/gcp/bigtable/BigtableWriteIT.java
- sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIOReadTest.java 11 个添加, 39 个删除...org/apache/beam/sdk/io/gcp/spanner/SpannerIOReadTest.java
- sdks/java/io/google-cloud-platform/src/test/java/org/apache/beam/sdk/io/gcp/spanner/SpannerIOWriteTest.java 12 个添加, 65 个删除...rg/apache/beam/sdk/io/gcp/spanner/SpannerIOWriteTest.java
- sdks/java/io/jdbc/src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOTest.java 5 个添加, 6 个删除...src/test/java/org/apache/beam/sdk/io/jdbc/JdbcIOTest.java
加载中
想要评论请 注册 或 登录