Merge pull request #12581 from [BEAM-10378] Add Azure Blob Storage Filesystem
* implemented an azure blob storage filesystem removed ignored test from this PR removed unused file fixed a typo small fixes small fixes small fixes small fixes for readability cleaning code small fixes ignore mockito config, move test file implemented an azure blob storage filesystem removed ignored test from this PR removed unused file fixed a typo small fixes small fixes small fixes small fixes for readability cleaning code small fixes ignore mockito config, move test file implemented an azure blob storage filesystem removed ignored test from this PR removed unused file fixed a typo small fixes small fixes small fixes small fixes for readability cleaning code small fixes ignore mockito config, move test file organized dependencies fixed a typo * added options to azure filesystem * added experimental annotation * adding mocks to azure filesystem tests * adding mocks to azure filesystem test * resolving various reviewer comments applied spotless to fix formatting * adding mocks to filesystem test * adding mocks to filesystem test * working on options and mocks * applied spotless * Update sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystem.java Co-authored-by:Pablo <pabloem@users.noreply.github.com> * incorporating reviewer feeback * fixed a checkstyle issue, annotated tests in progress with @Ignore * adding javadoc * fixing a bug in AzureReadableSeekableByteChannel read * removing logger from azure bytechannel * removed non-serializable option * removed non-serializable configuration option * removed integration tests - they will be in a followup PR Co-authored-by:
Pablo <pabloem@users.noreply.github.com>
显示
- build.gradle 1 个添加, 0 个删除build.gradle
- sdks/java/io/azure/build.gradle 18 个添加, 1 个删除sdks/java/io/azure/build.gradle
- sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/AzfsResourceId.java 45 个添加, 17 个删除...rg/apache/beam/sdk/io/azure/blobstore/AzfsResourceId.java
- sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystem.java 427 个添加, 14 个删除...beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystem.java
- sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystemRegistrar.java 8 个添加, 2 个删除...io/azure/blobstore/AzureBlobStoreFileSystemRegistrar.java
- sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/AzureReadableSeekableByteChannel.java 120 个添加, 0 个删除.../io/azure/blobstore/AzureReadableSeekableByteChannel.java
- sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/blobstore/DefaultBlobstoreClientBuilderFactory.java 79 个添加, 0 个删除...azure/blobstore/DefaultBlobstoreClientBuilderFactory.java
- sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/options/AzurePipelineOptionsRegistrar.java 35 个添加, 0 个删除...m/sdk/io/azure/options/AzurePipelineOptionsRegistrar.java
- sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/options/BlobstoreClientBuilderFactory.java 25 个添加, 0 个删除...m/sdk/io/azure/options/BlobstoreClientBuilderFactory.java
- sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/options/BlobstoreOptions.java 134 个添加, 0 个删除...rg/apache/beam/sdk/io/azure/options/BlobstoreOptions.java
- sdks/java/io/azure/src/main/java/org/apache/beam/sdk/io/azure/options/package-info.java 23 个添加, 0 个删除...va/org/apache/beam/sdk/io/azure/options/package-info.java
- sdks/java/io/azure/src/test/java/org/apache/beam/sdk/io/azure/blobstore/AzfsResourceIdTest.java 12 个添加, 13 个删除...pache/beam/sdk/io/azure/blobstore/AzfsResourceIdTest.java
- sdks/java/io/azure/src/test/java/org/apache/beam/sdk/io/azure/blobstore/AzureBlobStoreFileSystemTest.java 352 个添加, 0 个删除.../sdk/io/azure/blobstore/AzureBlobStoreFileSystemTest.java
- sdks/java/io/azure/src/test/resources/in.txt 23 个添加, 0 个删除sdks/java/io/azure/src/test/resources/in.txt
- sdks/java/io/azure/src/test/resources/mockito-extensions/org.mockito.plugins.MockMaker 1 个添加, 0 个删除...esources/mockito-extensions/org.mockito.plugins.MockMaker
加载中
想要评论请 注册 或 登录