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 |