b30adb0ce90d8f81f8028aeb5d541a3a67e6543d
Files Diff
- Added: 0
- Removed: 1
- Renamed: 0
- Modified: 9
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Method | 1 | ||
| Extract Method public initializeEmptyState() : void extracted from public open() : void in class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness | From | To | |
| Extract And Move Method | 2 | ||
| Extract And Move Method public initializeEmptyState() : void extracted from private testRescaling(initialParallelism int, numPartitions int, restoredParallelism int, restoredNumPartitions int) : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest & moved to class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness | From | To | |
| Extract And Move Method public initializeEmptyState() : void extracted from public testPeriodicWatermark() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest & moved to class org.apache.flink.streaming.util.AbstractStreamOperatorTestHarness | From | To |