f75c33d81993240b0a67feffc348aa19dc6c2834
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 9
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Extract Method | 5 | ||
| Extract Method private mockKinesisDataFetcher() : KinesisDataFetcher extracted from public testFetcherShouldBeCorrectlySeededOnlyItsOwnStates() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest | From | To | |
| Extract Method private mockKinesisDataFetcher() : KinesisDataFetcher extracted from public testFetcherShouldBeCorrectlySeededWithNewDiscoveredKinesisStreamShard() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest | From | To | |
| Extract Method private mockKinesisDataFetcher() : KinesisDataFetcher extracted from public testFetcherShouldBeCorrectlySeededIfRestoringFromCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest | From | To | |
| Extract Method private mockKinesisDataFetcher() : KinesisDataFetcher extracted from public testFetcherShouldNotBeRestoringFromFailureIfNotRestoringFromCheckpoint() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest | From | To | |
| Extract Method private mockKinesisDataFetcher() : KinesisDataFetcher extracted from public testFindSequenceNumberToRestoreFromIfTheShardHasBeenClosedSinceTheStateWasStored() : void in class org.apache.flink.streaming.connectors.kinesis.FlinkKinesisConsumerTest | From | To |