0579f90bab165a7df336163eb9d6337267020029
Files Diff
- Added: 2
- Removed: 1
- Renamed: 0
- Modified: 14
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 2 | ||
| Rename Method public getNumberOfTempDirs() : int renamed to public getNumberOfSpillingDirectories() : int in class org.apache.flink.runtime.io.disk.iomanager.IOManager | From | To | |
| Rename Method private blockChannel(channelIndex int) : void renamed to private onBarrier(channelIndex int) : void in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Change Parameter Type | 2 | ||
| Change Parameter Type reader : AbstractReader to ioManager : IOManager in method public BarrierBuffer(inputGate InputGate, ioManager IOManager) in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Change Parameter Type event : TaskEvent to barrier : CheckpointBarrier in method public onEvent(barrier CheckpointBarrier) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.CheckpointBarrierListener | From | To | |
| Rename Variable | 1 | ||
| Rename Variable bufferOrEvent : BufferOrEvent to next : BufferOrEvent in method public getNextNonBlocked() : BufferOrEvent in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Inline Method | 1 | ||
| Inline Method private actOnAllBlocked() : void inlined to public getNextNonBlocked() : BufferOrEvent in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Change Return Type | 1 | ||
| Change Return Type EventListener<TaskEvent> to EventListener<CheckpointBarrier> in method public getCheckpointBarrierListener() : EventListener<CheckpointBarrier> in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.streaming.runtime.io.BarrierBufferIOTest.MockInputGate moved and renamed to org.apache.flink.streaming.runtime.io.BarrierBufferMassiveRandomTest.RandomGeneratingInputGate | From | To | |
| Move Class | 3 | ||
| Move Class org.apache.flink.streaming.runtime.io.BarrierBufferIOTest.RandomBarrier moved to org.apache.flink.streaming.runtime.io.BarrierBufferMassiveRandomTest.RandomBarrier | From | To | |
| Move Class org.apache.flink.streaming.runtime.io.BarrierBufferIOTest.CountBarrier moved to org.apache.flink.streaming.runtime.io.BarrierBufferMassiveRandomTest.CountBarrier | From | To | |
| Move Class org.apache.flink.streaming.runtime.io.BarrierBufferIOTest.BarrierGenerator moved to org.apache.flink.streaming.runtime.io.BarrierBufferMassiveRandomTest.BarrierGenerator | From | To | |
| Parameterize Variable | 1 | ||
| Parameterize Variable sStep : CheckpointBarrier to barrier : CheckpointBarrier in method public onEvent(barrier CheckpointBarrier) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.CheckpointBarrierListener | From | To | |
| Rename Attribute | 4 | ||
| Rename Attribute rnd : Random to RND : Random in class org.apache.flink.streaming.runtime.io.BufferSpiller | From | To | |
| Rename Attribute inputFinished : boolean to endOfStream : boolean in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Rename Attribute barrierBuffer : BarrierBuffer to barrierHandler : CheckpointBarrierHandler in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Rename Attribute barrierBuffer : BarrierBuffer to barrierHandler : CheckpointBarrierHandler in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Extract Interface | 1 | ||
| Extract Interface org.apache.flink.streaming.runtime.io.CheckpointBarrierHandler from classes [org.apache.flink.streaming.runtime.io.BarrierBuffer] | From | To | |
| Change Attribute Type | 7 | ||
| Change Attribute Type checkpointBarrierListener : EventListener<TaskEvent> to checkpointBarrierListener : EventListener<CheckpointBarrier> in class org.apache.flink.streaming.runtime.tasks.StreamTask | From | To | |
| Change Attribute Type barrierBuffer : BarrierBuffer to barrierHandler : CheckpointBarrierHandler in class org.apache.flink.streaming.runtime.io.StreamInputProcessor | From | To | |
| Change Attribute Type blockedNonProcessed : Queue<SpillingBufferOrEvent> to blockedNonProcessed : ArrayDeque<SpillingBufferOrEvent> in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Change Attribute Type barrierBuffer : BarrierBuffer to barrierHandler : CheckpointBarrierHandler in class org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | From | To | |
| Change Attribute Type tempDir : String to tempDir : File in class org.apache.flink.streaming.runtime.io.BufferSpiller | From | To | |
| Change Attribute Type blockedChannels : Set<Integer> to blockedChannels : boolean[] in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Change Attribute Type nonProcessed : Queue<SpillingBufferOrEvent> to nonProcessed : ArrayDeque<SpillingBufferOrEvent> in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter actual : BufferOrEvent to present : BufferOrEvent in method private check(expected BufferOrEvent, present BufferOrEvent) : void in class org.apache.flink.streaming.runtime.io.BarrierBufferTest | From | To | |
| Rename Parameter reader : AbstractReader to ioManager : IOManager in method public BarrierBuffer(inputGate InputGate, ioManager IOManager) in class org.apache.flink.streaming.runtime.io.BarrierBuffer | From | To | |
| Rename Parameter event : TaskEvent to barrier : CheckpointBarrier in method public onEvent(barrier CheckpointBarrier) : void in class org.apache.flink.streaming.runtime.tasks.StreamTask.CheckpointBarrierListener | From | To |