ierandra commented on code in PR #2160:
URL: https://github.com/apache/jackrabbit-oak/pull/2160#discussion_r1999263192
##########
oak-segment-azure/src/main/java/org/apache/jackrabbit/oak/segment/azure/tool/AzureCompact.java:
##########
@@ -321,22 +348,26 @@ private AzureCompact(Builder builder) {
this.persistentCacheSizeGb = builder.persistentCacheSizeGb;
this.garbageThresholdGb = builder.garbageThresholdGb;
this.garbageThresholdPercentage = builder.garbageThresholdPercentage;
- this.sourceCloudBlobDirectory = builder.sourceCloudBlobDirectory;
- this.destinationCloudBlobDirectory =
builder.destinationCloudBlobDirectory;
- this.azureStorageCredentialManagerV8 = new
AzureStorageCredentialManagerV8();
+ this.sourceBlobContainerClient = builder.sourceBlobContainerClient;
+ this.destinationBlobContainerClient =
builder.destinationBlobContainerClient;
}
- public int run() throws IOException, StorageException, URISyntaxException {
+ public int run() throws IOException, URISyntaxException {
Stopwatch watch = Stopwatch.createStarted();
SegmentNodeStorePersistence roPersistence;
SegmentNodeStorePersistence rwPersistence;
- if (sourceCloudBlobDirectory != null && destinationCloudBlobDirectory
!= null) {
- roPersistence = new AzurePersistenceV8(sourceCloudBlobDirectory);
- rwPersistence = new
AzurePersistenceV8(destinationCloudBlobDirectory);
+ BlobContainerClient targetContainer;
+ if (sourceBlobContainerClient != null &&
destinationBlobContainerClient != null) {
+ roPersistence = new AzurePersistence(sourceBlobContainerClient,
rootPrefix);
+ rwPersistence = new
AzurePersistence(destinationBlobContainerClient, rootPrefix);
Review Comment:
thanks. fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
