b2f8e3070b8db16093f36680f9c8ce124aae8627
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Rename Variable | 2 | ||
Rename Variable b : Buffer to buffer : Buffer in method public clearBuffers() : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriter | From | To | |
Rename Variable s : RecordSerializer<?> to serializer : RecordSerializer<?> in method public clearBuffers() : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriter | From | To | |
Extract Method | 5 | ||
Extract Method private writeBuffer(buffer Buffer, targetChannel int, serializer RecordSerializer<T>) : void extracted from public broadcastEvent(event AbstractEvent) : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriter | From | To | |
Extract Method private writeBuffer(buffer Buffer, targetChannel int, serializer RecordSerializer<T>) : void extracted from public sendEndOfSuperstep() : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriter | From | To | |
Extract Method private writeBuffer(buffer Buffer, targetChannel int, serializer RecordSerializer<T>) : void extracted from public flush() : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriter | From | To | |
Extract Method private writeBuffer(buffer Buffer, targetChannel int, serializer RecordSerializer<T>) : void extracted from public emit(record T) : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriter | From | To | |
Extract Method private writeBuffer(buffer Buffer, targetChannel int, serializer RecordSerializer<T>) : void extracted from public broadcastEmit(record T) : void in class org.apache.flink.runtime.io.network.api.writer.RecordWriter | From | To |