58ca87aaeb910dd0d3cf28b9a65e81b9af455690
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 1
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Variable | 3 | ||
| Rename Variable lastTimeNanos : long to loopFrequencyHz : double in method private adaptRecordsToRead(runLoopTimeNanos long, numRecords int, recordBatchSizeBytes long, maxNumberOfRecordsPerFetch int) : int in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer | From | To | |
| Rename Variable elapsedTimeNanos : long to processingTimeNanos : long in method protected adjustRunLoopFrequency(processingStartTimeNanos long, processingEndTimeNanos long) : long in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer | From | To | |
| Rename Variable lastTimeNanos : long to processingStartTimeNanos : long in method public run() : void in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer | From | To | |
| Change Variable Type | 1 | ||
| Change Variable Type lastTimeNanos : long to loopFrequencyHz : double in method private adaptRecordsToRead(runLoopTimeNanos long, numRecords int, recordBatchSizeBytes long, maxNumberOfRecordsPerFetch int) : int in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer | From | To | |
| Extract Method | 2 | ||
| Extract Method private adaptRecordsToRead(runLoopTimeNanos long, numRecords int, recordBatchSizeBytes long, maxNumberOfRecordsPerFetch int) : int extracted from public run() : void in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer | From | To | |
| Extract Method protected adjustRunLoopFrequency(processingStartTimeNanos long, processingEndTimeNanos long) : long extracted from public run() : void in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer | From | To |