|
Change Parameter Type fileSystemWriter : RecoverableWriter to stream : RecoverableFsDataOutputStream in method public resumeFrom(bucketId BucketID, stream RecoverableFsDataOutputStream, resumable RecoverableWriter.ResumeRecoverable, creationTime long) : PartFileWriter<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.PartFileWriter.PartFileFactory |
From |
To |
|
Change Parameter Type fileSystemWriter : RecoverableWriter to stream : RecoverableFsDataOutputStream in method public resumeFrom(bucketId BucketID, stream RecoverableFsDataOutputStream, resumable RecoverableWriter.ResumeRecoverable, creationTime long) : PartFileWriter<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.BulkPartWriter.Factory |
From |
To |
|
Change Parameter Type fileSystemWriter : RecoverableWriter to stream : RecoverableFsDataOutputStream in method public openNew(bucketId BucketID, stream RecoverableFsDataOutputStream, path Path, creationTime long) : PartFileWriter<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.PartFileWriter.PartFileFactory |
From |
To |
|
Change Parameter Type fileSystemWriter : RecoverableWriter to stream : RecoverableFsDataOutputStream in method public resumeFrom(bucketId BucketID, stream RecoverableFsDataOutputStream, resumable RecoverableWriter.ResumeRecoverable, creationTime long) : PartFileWriter<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.RowWisePartWriter.Factory |
From |
To |
|
Change Parameter Type fileSystemWriter : RecoverableWriter to stream : RecoverableFsDataOutputStream in method public openNew(bucketId BucketID, stream RecoverableFsDataOutputStream, path Path, creationTime long) : PartFileWriter<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.RowWisePartWriter.Factory |
From |
To |
|
Change Parameter Type fileSystemWriter : RecoverableWriter to stream : RecoverableFsDataOutputStream in method public openNew(bucketId BucketID, stream RecoverableFsDataOutputStream, path Path, creationTime long) : PartFileWriter<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.BulkPartWriter.Factory |
From |
To |
|
Rename Parameter fileSystemWriter : RecoverableWriter to stream : RecoverableFsDataOutputStream in method public openNew(bucketId BucketID, stream RecoverableFsDataOutputStream, path Path, creationTime long) : PartFileWriter<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.RowWisePartWriter.Factory |
From |
To |
|
Rename Parameter fileSystemWriter : RecoverableWriter to stream : RecoverableFsDataOutputStream in method public openNew(bucketId BucketID, stream RecoverableFsDataOutputStream, path Path, creationTime long) : PartFileWriter<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.BulkPartWriter.Factory |
From |
To |
|
Rename Parameter fileSystemWriter : RecoverableWriter to stream : RecoverableFsDataOutputStream in method public resumeFrom(bucketId BucketID, stream RecoverableFsDataOutputStream, resumable RecoverableWriter.ResumeRecoverable, creationTime long) : PartFileWriter<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.PartFileWriter.PartFileFactory |
From |
To |
|
Rename Parameter fileSystemWriter : RecoverableWriter to stream : RecoverableFsDataOutputStream in method public resumeFrom(bucketId BucketID, stream RecoverableFsDataOutputStream, resumable RecoverableWriter.ResumeRecoverable, creationTime long) : PartFileWriter<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.BulkPartWriter.Factory |
From |
To |
|
Rename Parameter fileSystemWriter : RecoverableWriter to stream : RecoverableFsDataOutputStream in method public resumeFrom(bucketId BucketID, stream RecoverableFsDataOutputStream, resumable RecoverableWriter.ResumeRecoverable, creationTime long) : PartFileWriter<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.RowWisePartWriter.Factory |
From |
To |
|
Rename Parameter fileSystemWriter : RecoverableWriter to stream : RecoverableFsDataOutputStream in method public openNew(bucketId BucketID, stream RecoverableFsDataOutputStream, path Path, creationTime long) : PartFileWriter<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.PartFileWriter.PartFileFactory |
From |
To |