8e23264a4511d33723a756abc209c289fafbe97d
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 2
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Extract Method | 2 | ||
Extract Method private getMockStreamShard(streamName String, shardId int) : StreamShardHandle extracted from public testCorrectNumOfCollectedRecordsAndUpdatedStateWithUnexpectedExpiredIterator() : void in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumerTest | From | To | |
Extract Method private getMockStreamShard(streamName String, shardId int) : StreamShardHandle extracted from public testCorrectNumOfCollectedRecordsAndUpdatedState() : void in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumerTest | From | To |