|
Change Return Type RecoverableWriter.CommitRecoverable to CommitRecoverable in method private closePartFile() : CommitRecoverable in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Return Type SimpleVersionedSerializer<RecoverableWriter.CommitRecoverable> to SimpleVersionedSerializer<CommitRecoverable> in method public getCommitRecoverableSerializer() : SimpleVersionedSerializer<CommitRecoverable> in class org.apache.flink.fs.s3.common.writer.S3RecoverableWriter |
From |
To |
|
Change Return Type SimpleVersionedSerializer<RecoverableWriter.ResumeRecoverable> to SimpleVersionedSerializer<ResumeRecoverable> in method public getResumeRecoverableSerializer() : SimpleVersionedSerializer<ResumeRecoverable> in class org.apache.flink.fs.s3.common.writer.S3RecoverableWriter |
From |
To |
|
Change Return Type List<RecoverableWriter.CommitRecoverable> to List<CommitRecoverable> in method package getPendingPartsForCurrentCheckpoint() : List<CommitRecoverable> in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Return Type Map<Long,List<RecoverableWriter.CommitRecoverable>> to Map<Long,List<CommitRecoverable>> in method package getPendingPartsPerCheckpoint() : Map<Long,List<CommitRecoverable>> in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Variable Type committables : List<RecoverableWriter.CommitRecoverable> to committables : List<CommitRecoverable> in method private commitRecoveredPendingFiles(state BucketState<BucketID>) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Variable Type committable : RecoverableWriter.CommitRecoverable to committable : CommitRecoverable in method package onSuccessfulCompletionOfCheckpoint(checkpointId long) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Variable Type entry : Map.Entry<Long,List<RecoverableWriter.CommitRecoverable>> to entry : Map.Entry<Long,List<CommitRecoverable>> in method package onSuccessfulCompletionOfCheckpoint(checkpointId long) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Variable Type committable : RecoverableWriter.CommitRecoverable to committable : CommitRecoverable in method package merge(bucket Bucket<IN,BucketID>) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Variable Type committable : RecoverableWriter.CommitRecoverable to committable : CommitRecoverable in method private commitRecoveredPendingFiles(state BucketState<BucketID>) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Variable Type inProgressResumable : RecoverableWriter.ResumeRecoverable to inProgressResumable : ResumeRecoverable in method package onReceptionOfCheckpoint(checkpointId long) : BucketState<BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Variable Type it : Iterator<Map.Entry<Long,List<RecoverableWriter.CommitRecoverable>>> to it : Iterator<Map.Entry<Long,List<CommitRecoverable>>> in method package onSuccessfulCompletionOfCheckpoint(checkpointId long) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Variable Type committable : RecoverableWriter.CommitRecoverable to committable : CommitRecoverable in method private closePartFile() : CommitRecoverable in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Variable Type resumable : RecoverableWriter.ResumeRecoverable to resumable : ResumeRecoverable in method private restoreInProgressFile(state BucketState<BucketID>) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |