dd4b3d1fd3de9c64d077c67bcf740ba347e81a3a
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 5
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type kinesis : KinesisProxyInterface to kinesisProxyFactory : FlinkKinesisProxyFactory in method protected KinesisDataFetcher(streams List<String>, sourceContext SourceFunction.SourceContext<T>, checkpointLock Object, runtimeContext RuntimeContext, configProps Properties, deserializationSchema KinesisDeserializationSchema<T>, shardAssigner KinesisShardAssigner, error AtomicReference<Throwable>, subscribedShardsState List<KinesisStreamShardState>, subscribedStreamsToLastDiscoveredShardIds HashMap<String,String>, kinesisProxyFactory FlinkKinesisProxyFactory) in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher | From | To | |
| Extract Method | 1 | ||
| Extract Method protected getInitialShardIterator() : String extracted from public run() : void in class org.apache.flink.streaming.connectors.kinesis.internals.ShardConsumer | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter kinesis : KinesisProxyInterface to kinesisProxyFactory : FlinkKinesisProxyFactory in method protected KinesisDataFetcher(streams List<String>, sourceContext SourceFunction.SourceContext<T>, checkpointLock Object, runtimeContext RuntimeContext, configProps Properties, deserializationSchema KinesisDeserializationSchema<T>, shardAssigner KinesisShardAssigner, error AtomicReference<Throwable>, subscribedShardsState List<KinesisStreamShardState>, subscribedStreamsToLastDiscoveredShardIds HashMap<String,String>, kinesisProxyFactory FlinkKinesisProxyFactory) in class org.apache.flink.streaming.connectors.kinesis.internals.KinesisDataFetcher | From | To |