|
Change Parameter Type callback : RequestDoneCallback to callback : RequestDoneCallback<T> in method protected AsynchronousFileIOChannel(channelID FileIOChannel.ID, requestQueue RequestQueue<R>, callback RequestDoneCallback<T>, writeEnabled boolean) in class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannel |
From |
To |
|
Change Parameter Type targetChannel : AsynchronousFileIOChannel<WriteRequest> to targetChannel : AsynchronousFileIOChannel<MemorySegment,WriteRequest> in method protected FailingWriteRequest(targetChannel AsynchronousFileIOChannel<MemorySegment,WriteRequest>, segment MemorySegment) in class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannelsTest.FailingWriteRequest |
From |
To |
|
Change Parameter Type callback : RequestDoneCallback to callback : RequestDoneCallback<MemorySegment> in method public createBlockChannelWriter(channelID ID, callback RequestDoneCallback<MemorySegment>) : BlockChannelWriterWithCallback in class org.apache.flink.runtime.io.disk.iomanager.IOManagerTest.TestIOManager |
From |
To |
|
Change Variable Type callback : RequestDoneCallback to callback : RequestDoneCallback<MemorySegment> in method public testClosingWaits() : void in class org.apache.flink.runtime.io.disk.iomanager.AsynchronousFileIOChannelsTest |
From |
To |
|
Change Variable Type result : SerializationResult to result : RecordSerializer.SerializationResult in method private test(records Util.MockRecords, segmentSize int) : void in class org.apache.flink.runtime.io.network.api.serialization.SpanningRecordSerializerTest |
From |
To |
|
Change Variable Type result : SerializationResult to result : RecordSerializer.SerializationResult in method public testEmptyRecords() : void in class org.apache.flink.runtime.io.network.api.serialization.SpanningRecordSerializerTest |
From |
To |
|
Change Variable Type result : DeserializationResult to result : RecordDeserializer.DeserializationResult in method private test(records Util.MockRecords, segmentSize int, serializer RecordSerializer<SerializationTestType>, deserializer RecordDeserializer<SerializationTestType>) : void in class org.apache.flink.runtime.io.network.api.serialization.SpanningRecordSerializationTest |
From |
To |