|
Change Parameter Type s3uploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method package UploadTask(s3AccessHelper S3AccessHelper, currentUpload MultiPartUploadInfo, file RefCountedFSOutputStream, future CompletableFuture<PartETag>) in class org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUploadImpl.UploadTask |
From |
To |
|
Change Parameter Type s3UploadHelper : S3MultiPartUploader to s3UploadHelper : S3AccessHelper in method public FlinkS3FileSystem(hadoopS3FileSystem FileSystem, localTmpDirectory String, entropyInjectionKey String, entropyLength int, s3UploadHelper S3AccessHelper, s3uploadPartSize long, maxConcurrentUploadsPerStream int) in class org.apache.flink.fs.s3.common.FlinkS3FileSystem |
From |
To |
|
Change Parameter Type s3uploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method public newUpload(s3AccessHelper S3AccessHelper, uploadThreadPool Executor, objectName String) : RecoverableMultiPartUploadImpl in class org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUploadImpl |
From |
To |
|
Change Parameter Type twoPhaseUploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method public writer(fs FileSystem, tempFileCreator FunctionWithException<File,RefCountedFile,IOException>, s3AccessHelper S3AccessHelper, uploadThreadPool Executor, userDefinedMinPartSize long, maxConcurrentUploadsPerStream int) : S3RecoverableWriter in class org.apache.flink.fs.s3.common.writer.S3RecoverableWriter |
From |
To |
|
Change Parameter Type s3uploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method private RecoverableMultiPartUploadImpl(s3AccessHelper S3AccessHelper, uploadThreadPool Executor, uploadId String, objectName String, partsSoFar List<PartETag>, numBytes long, incompletePart Optional<File>) in class org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUploadImpl |
From |
To |
|
Change Parameter Type s3uploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method package S3Committer(s3AccessHelper S3AccessHelper, objectName String, uploadId String, parts List<PartETag>, totalLength long) in class org.apache.flink.fs.s3.common.writer.S3Committer |
From |
To |
|
Change Parameter Type s3uploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method public recoverUpload(s3AccessHelper S3AccessHelper, uploadThreadPool Executor, multipartUploadId String, objectName String, partsSoFar List<PartETag>, numBytesSoFar long, incompletePart Optional<File>) : RecoverableMultiPartUploadImpl in class org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUploadImpl |
From |
To |
|
Change Parameter Type twoPhaseUploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method package S3RecoverableMultipartUploadFactory(fs FileSystem, s3AccessHelper S3AccessHelper, maxConcurrentUploadsPerStream int, executor Executor, tmpFileSupplier FunctionWithException<File,RefCountedFile,IOException>) in class org.apache.flink.fs.s3.common.writer.S3RecoverableMultipartUploadFactory |
From |
To |
|
Rename Attribute s3uploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in class org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUploadImpl.UploadTask |
From |
To |
|
Rename Attribute s3uploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in class org.apache.flink.fs.s3.common.writer.S3Committer |
From |
To |
|
Rename Attribute s3MPUploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in class org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUploadImpl |
From |
To |
|
Rename Attribute twoPhaseUploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in class org.apache.flink.fs.s3.common.writer.S3RecoverableMultipartUploadFactory |
From |
To |
|
Rename Attribute s3uploader : InternalWriteOperationHelper to s3accessHelper : InternalWriteOperationHelper in class org.apache.flink.fs.s3hadoop.HadoopS3AccessHelper |
From |
To |
|
Rename Attribute s3UploadHelper : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in class org.apache.flink.fs.s3.common.FlinkS3FileSystem |
From |
To |
|
Rename Parameter s3uploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method public recoverUpload(s3AccessHelper S3AccessHelper, uploadThreadPool Executor, multipartUploadId String, objectName String, partsSoFar List<PartETag>, numBytesSoFar long, incompletePart Optional<File>) : RecoverableMultiPartUploadImpl in class org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUploadImpl |
From |
To |
|
Rename Parameter s3uploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method package S3Committer(s3AccessHelper S3AccessHelper, objectName String, uploadId String, parts List<PartETag>, totalLength long) in class org.apache.flink.fs.s3.common.writer.S3Committer |
From |
To |
|
Rename Parameter twoPhaseUploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method package S3RecoverableMultipartUploadFactory(fs FileSystem, s3AccessHelper S3AccessHelper, maxConcurrentUploadsPerStream int, executor Executor, tmpFileSupplier FunctionWithException<File,RefCountedFile,IOException>) in class org.apache.flink.fs.s3.common.writer.S3RecoverableMultipartUploadFactory |
From |
To |
|
Rename Parameter s3uploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method package UploadTask(s3AccessHelper S3AccessHelper, currentUpload MultiPartUploadInfo, file RefCountedFSOutputStream, future CompletableFuture<PartETag>) in class org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUploadImpl.UploadTask |
From |
To |
|
Rename Parameter twoPhaseUploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method public writer(fs FileSystem, tempFileCreator FunctionWithException<File,RefCountedFile,IOException>, s3AccessHelper S3AccessHelper, uploadThreadPool Executor, userDefinedMinPartSize long, maxConcurrentUploadsPerStream int) : S3RecoverableWriter in class org.apache.flink.fs.s3.common.writer.S3RecoverableWriter |
From |
To |
|
Rename Parameter s3uploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method public newUpload(s3AccessHelper S3AccessHelper, uploadThreadPool Executor, objectName String) : RecoverableMultiPartUploadImpl in class org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUploadImpl |
From |
To |
|
Rename Parameter s3uploader : S3MultiPartUploader to s3AccessHelper : S3AccessHelper in method private RecoverableMultiPartUploadImpl(s3AccessHelper S3AccessHelper, uploadThreadPool Executor, uploadId String, objectName String, partsSoFar List<PartETag>, numBytes long, incompletePart Optional<File>) in class org.apache.flink.fs.s3.common.writer.RecoverableMultiPartUploadImpl |
From |
To |