942649e933f3106d923c567c705d75fc9aa0a40c
Files Diff
- Added: 1
- Removed: 0
- Renamed: 0
- Modified: 6
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type shard : StreamShardHandle to shardHash : int in method public isThisSubtaskShouldSubscribeTo(shardHash int, totalNumberOfConsumerSubtasks int, indexOfThisConsumerSubtask int) : boolean in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter shard : StreamShardHandle to shardHash : int in method public isThisSubtaskShouldSubscribeTo(shardHash int, totalNumberOfConsumerSubtasks int, indexOfThisConsumerSubtask int) : boolean in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher | From | To |