37cdaf976ff198a6e5c1d0e6e38a50de185cec1e
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Attribute | 1 | ||
| Rename Attribute fixedMockGetAllTopicsReturnSequence : List<String> to testPartitionDiscoverer : AbstractPartitionDiscoverer in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest.DummyFlinkKafkaConsumer | From | To | |
| Change Variable Type | 3 | ||
| Change Variable Type fetcher : AbstractFetcher<String,?> to fetcher : AbstractFetcher<T,?> in method private getRunnableMockFetcher(runLatch OneShotLatch, stopLatch OneShotLatch) : AbstractFetcher<T,?> in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To | |
| Change Variable Type restoredListState : TestingListState<Serializable> to restoredListState : TestingListState<Tuple2<KafkaTopicPartition,Long>> in method public checkRestoredCheckpointWhenFetcherNotReady() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type fixedMockGetAllTopicsReturnSequence : List<String> to testPartitionDiscoverer : AbstractPartitionDiscoverer in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest.DummyFlinkKafkaConsumer | From | To | |
| Extract Method | 9 | ||
| Extract Method private setupConsumer(consumer FlinkKafkaConsumerBase<T>, isRestored boolean, restoredListState ListState<S>, isCheckpointingEnabled boolean, subtaskIndex int, totalNumSubtasks int) : void extracted from public testConfigureDisableOffsetCommitWithCheckpointing() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To | |
| Extract Method private setupConsumer(consumer FlinkKafkaConsumerBase<T>, isRestored boolean, restoredListState ListState<S>, isCheckpointingEnabled boolean, subtaskIndex int, totalNumSubtasks int) : void extracted from public testConfigureDisableOffsetCommitWithoutCheckpointing() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To | |
| Extract Method private setupConsumer(consumer FlinkKafkaConsumerBase<T>, isRestored boolean, restoredListState ListState<S>, isCheckpointingEnabled boolean, subtaskIndex int, totalNumSubtasks int) : void extracted from public testSnapshotStateWithCommitOnCheckpointsEnabled() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To | |
| Extract Method private setupConsumer(consumer FlinkKafkaConsumerBase<T>, isRestored boolean, restoredListState ListState<S>, isCheckpointingEnabled boolean, subtaskIndex int, totalNumSubtasks int) : void extracted from public testConfigureOnCheckpointsCommitMode() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To | |
| Extract Method private setupConsumer(consumer FlinkKafkaConsumerBase<T>, isRestored boolean, restoredListState ListState<S>, isCheckpointingEnabled boolean, subtaskIndex int, totalNumSubtasks int) : void extracted from public testConfigureAutoCommitMode() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To | |
| Extract Method private setupConsumer(consumer FlinkKafkaConsumerBase<T>, isRestored boolean, restoredListState ListState<S>, isCheckpointingEnabled boolean, subtaskIndex int, totalNumSubtasks int) : void extracted from public testSnapshotStateWithCommitOnCheckpointsDisabled() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To | |
| Extract Method private setupConsumer(consumer FlinkKafkaConsumerBase<T>, isRestored boolean, restoredListState ListState<S>, isCheckpointingEnabled boolean, subtaskIndex int, totalNumSubtasks int) : void extracted from public checkRestoredCheckpointWhenFetcherNotReady() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To | |
| Extract Method private getRunnableMockFetcher(runLatch OneShotLatch, stopLatch OneShotLatch) : AbstractFetcher<T,?> extracted from public testSnapshotStateWithCommitOnCheckpointsEnabled() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To | |
| Extract Method private getRunnableMockFetcher(runLatch OneShotLatch, stopLatch OneShotLatch) : AbstractFetcher<T,?> extracted from public testSnapshotStateWithCommitOnCheckpointsDisabled() : void in class org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBaseTest | From | To |