cba78669137436db2e35179504bf40b5ba1ac50f
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 8
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type serializer : TypeSerializer<?> to serializer : TypeSerializer<StreamRecord<T>> in method protected staticCreateInputIterator(inputReader MutableReader<?>, serializer TypeSerializer<StreamRecord<T>>) : IndexedReaderIterator<StreamRecord<T>> in class org.apache.flink.streaming.api.streamvertex.InputHandler | From | To | |
| Change Return Type | 3 | ||
| Change Return Type MutableObjectIterator<StreamRecord<IN>> to IndexedReaderIterator<StreamRecord<IN>> in method public getInputIter() : IndexedReaderIterator<StreamRecord<IN>> in class org.apache.flink.streaming.api.streamvertex.InputHandler | From | To | |
| Change Return Type MutableObjectIterator<StreamRecord<IN>> to IndexedReaderIterator<StreamRecord<IN>> in method private createInputIterator() : IndexedReaderIterator<StreamRecord<IN>> in class org.apache.flink.streaming.api.streamvertex.InputHandler | From | To | |
| Change Return Type MutableObjectIterator<StreamRecord<T>> to IndexedReaderIterator<StreamRecord<T>> in method protected staticCreateInputIterator(inputReader MutableReader<?>, serializer TypeSerializer<StreamRecord<T>>) : IndexedReaderIterator<StreamRecord<T>> in class org.apache.flink.streaming.api.streamvertex.InputHandler | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.util.MockContext.MockInputIterator renamed to org.apache.flink.streaming.util.MockContext.IndexedInputIterator | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.streaming.io.IndexedReaderIterator from classes [org.apache.flink.streaming.util.MockContext.IndexedInputIterator] | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type reader : MutableReader<DeserializationDelegate<?>> to reader : IndexedMutableReader<DeserializationDelegate<StreamRecord<T>>> in method protected staticCreateInputIterator(inputReader MutableReader<?>, serializer TypeSerializer<StreamRecord<T>>) : IndexedReaderIterator<StreamRecord<T>> in class org.apache.flink.streaming.api.streamvertex.InputHandler | From | To | |
| Change Attribute Type | 4 | ||
| Change Attribute Type inputs : MutableReader<IOReadableWritable> to inputs : IndexedMutableReader<DeserializationDelegate<StreamRecord<IN>>> in class org.apache.flink.streaming.api.streamvertex.InputHandler | From | To | |
| Change Attribute Type inputIter : MutableObjectIterator<StreamRecord<IN>> to inputIter : IndexedReaderIterator<StreamRecord<IN>> in class org.apache.flink.streaming.api.streamvertex.InputHandler | From | To | |
| Change Attribute Type recordIterator : MutableObjectIterator<StreamRecord<IN>> to recordIterator : IndexedReaderIterator<StreamRecord<IN>> in class org.apache.flink.streaming.api.invokable.StreamInvokable | From | To | |
| Change Attribute Type iterator : MutableObjectIterator<StreamRecord<IN>> to iterator : IndexedReaderIterator<StreamRecord<IN>> in class org.apache.flink.streaming.util.MockContext | From | To |