|
Change Parameter Type s3client : AmazonS3 to blobStore : BlobStore in method public BlobStoreBackedInputStreamImpl(blobStore BlobStore, bucket String, key String, versionCheck VersionCheck, objectLen long, bufferSize int) in class org.apache.pulsar.broker.offload.impl.BlobStoreBackedInputStreamImpl |
From |
To |
|
Change Parameter Type s3client : AmazonS3 to blobStore : BlobStore in method public open(executor ScheduledExecutorService, blobStore BlobStore, bucket String, key String, indexKey String, versionCheck VersionCheck, ledgerId long, readBufferSize int) : ReadHandle in class org.apache.pulsar.broker.offload.impl.BlobStoreBackedReadHandleImpl |
From |
To |
|
Rename Variable mockS3client : AmazonS3 to spiedBlobStore : BlobStore in method public testOffloadFailDataBlockPartUpload() : void in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloaderTest |
From |
To |
|
Rename Variable mockS3client : AmazonS3 to spiedBlobStore : BlobStore in method public testOffloadFailDataBlockUploadComplete() : void in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloaderTest |
From |
To |
|
Rename Variable mockS3client : AmazonS3 to spiedBlobStore : BlobStore in method public testOffloadFailPutIndexBlock() : void in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloaderTest |
From |
To |
|
Rename Variable mockS3client : AmazonS3 to spiedBlobStore : BlobStore in method public testOffloadFailInitDataBlockUpload() : void in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloaderTest |
From |
To |
|
Rename Variable metadata : ObjectMetadata to blobBuilder : BlobBuilder in method public offload(readHandle ReadHandle, uuid UUID, extraMetadata Map<String,String>) : CompletableFuture<Void> in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloader |
From |
To |
|
Rename Variable dataMetadata : ObjectMetadata to blobBuilder : BlobBuilder in method public offload(readHandle ReadHandle, uuid UUID, extraMetadata Map<String,String>) : CompletableFuture<Void> in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloader |
From |
To |
|
Rename Variable dataBlockRes : InitiateMultipartUploadResult to mpu : MultipartUpload in method public offload(readHandle ReadHandle, uuid UUID, extraMetadata Map<String,String>) : CompletableFuture<Void> in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloader |
From |
To |
|
Rename Variable spiedClient : AmazonS3 to spiedBlobStore : BlobStore in method public testSeekWithinCurrent() : void in class org.apache.pulsar.broker.offload.BlobStoreBackedInputStreamTest |
From |
To |
|
Change Variable Type mockS3client : AmazonS3 to spiedBlobStore : BlobStore in method public testOffloadFailDataBlockUploadComplete() : void in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloaderTest |
From |
To |
|
Change Variable Type mockS3client : AmazonS3 to spiedBlobStore : BlobStore in method public testOffloadFailPutIndexBlock() : void in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloaderTest |
From |
To |
|
Change Variable Type mockS3client : AmazonS3 to spiedBlobStore : BlobStore in method public testOffloadFailInitDataBlockUpload() : void in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloaderTest |
From |
To |
|
Change Variable Type metadata : ObjectMetadata to blobBuilder : BlobBuilder in method public offload(readHandle ReadHandle, uuid UUID, extraMetadata Map<String,String>) : CompletableFuture<Void> in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloader |
From |
To |
|
Change Variable Type dataMetadata : ObjectMetadata to blobBuilder : BlobBuilder in method public offload(readHandle ReadHandle, uuid UUID, extraMetadata Map<String,String>) : CompletableFuture<Void> in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloader |
From |
To |
|
Change Variable Type dataBlockRes : InitiateMultipartUploadResult to mpu : MultipartUpload in method public offload(readHandle ReadHandle, uuid UUID, extraMetadata Map<String,String>) : CompletableFuture<Void> in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloader |
From |
To |
|
Change Variable Type spiedClient : AmazonS3 to spiedBlobStore : BlobStore in method public testSeekWithinCurrent() : void in class org.apache.pulsar.broker.offload.BlobStoreBackedInputStreamTest |
From |
To |
|
Change Variable Type mockS3client : AmazonS3 to spiedBlobStore : BlobStore in method public testOffloadFailDataBlockPartUpload() : void in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloaderTest |
From |
To |
|
Rename Parameter bucket : String to container : String in method package BlobStoreManagedLedgerOffloader(blobStore BlobStore, container String, scheduler OrderedScheduler, maxBlockSize int, readBufferSize int) in class org.apache.pulsar.broker.offload.impl.BlobStoreManagedLedgerOffloader |
From |
To |
|
Rename Parameter s3client : AmazonS3 to blobStore : BlobStore in method public BlobStoreBackedInputStreamImpl(blobStore BlobStore, bucket String, key String, versionCheck VersionCheck, objectLen long, bufferSize int) in class org.apache.pulsar.broker.offload.impl.BlobStoreBackedInputStreamImpl |
From |
To |
|
Rename Parameter s3client : AmazonS3 to blobStore : BlobStore in method public open(executor ScheduledExecutorService, blobStore BlobStore, bucket String, key String, indexKey String, versionCheck VersionCheck, ledgerId long, readBufferSize int) : ReadHandle in class org.apache.pulsar.broker.offload.impl.BlobStoreBackedReadHandleImpl |
From |
To |