|
Extract And Move Method public writeCompletely(channel WritableByteChannel, src ByteBuffer) : void extracted from public write() : void in class org.apache.flink.runtime.io.disk.iomanager.BufferWriteRequest & moved to class org.apache.flink.util.FileUtils |
From |
To |
|
Extract And Move Method public writeCompletely(channel WritableByteChannel, src ByteBuffer) : void extracted from public testIncompleteHeaderOnFirstElement() : void in class org.apache.flink.streaming.runtime.io.SpilledBufferOrEventSequenceTest & moved to class org.apache.flink.util.FileUtils |
From |
To |
|
Extract And Move Method public writeCompletely(channel WritableByteChannel, src ByteBuffer) : void extracted from private generateAndWriteEvent(fileChannel FileChannel, rnd Random, numChannels int) : BufferOrEvent in class org.apache.flink.streaming.runtime.io.SpilledBufferOrEventSequenceTest & moved to class org.apache.flink.util.FileUtils |
From |
To |
|
Extract And Move Method public writeCompletely(channel WritableByteChannel, src ByteBuffer) : void extracted from public testCleanup() : void in class org.apache.flink.streaming.runtime.io.SpilledBufferOrEventSequenceTest & moved to class org.apache.flink.util.FileUtils |
From |
To |
|
Extract And Move Method public writeCompletely(channel WritableByteChannel, src ByteBuffer) : void extracted from public testBufferSequenceWithIncompleteBuffer() : void in class org.apache.flink.streaming.runtime.io.SpilledBufferOrEventSequenceTest & moved to class org.apache.flink.util.FileUtils |
From |
To |
|
Extract And Move Method public writeCompletely(channel WritableByteChannel, src ByteBuffer) : void extracted from private writeBuffer(fileChannel FileChannel, size int, channelIndex int) : void in class org.apache.flink.streaming.runtime.io.SpilledBufferOrEventSequenceTest & moved to class org.apache.flink.util.FileUtils |
From |
To |
|
Extract And Move Method public writeCompletely(channel WritableByteChannel, src ByteBuffer) : void extracted from public add(boe BufferOrEvent) : void in class org.apache.flink.streaming.runtime.io.BufferSpiller & moved to class org.apache.flink.util.FileUtils |
From |
To |