2425885c0391da04ff600c538fe56081dc44ab1f
Files Diff
- Added: 6
- Removed: 0
- Renamed: 0
- Modified: 17
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type numThreads : int to deserializationScheme : DeserializationScheme<OUT> in method public KafkaSource(zkQuorum String, groupId String, topicId String, deserializationScheme DeserializationScheme<OUT>) in class org.apache.flink.streaming.connectors.kafka.KafkaSource | From | To | |
| Rename Variable | 1 | ||
| Rename Variable tuple : OUT to out : OUT in method private collect(avroEvent AvroFlumeEvent) : void in class org.apache.flink.streaming.connectors.flume.FlumeSource.MyAvroSource | From | To | |
| Change Return Type | 1 | ||
| Change Return Type String to byte[] in method public serialize(element String) : byte[] in class org.apache.flink.streaming.connectors.rabbitmq.RMQTopology.StringToByteSerializer | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.streaming.connectors.flume.FlumeTopology.MyFlumeSink renamed to org.apache.flink.streaming.connectors.flume.FlumeTopology.StringToByteSerializer | From | To | |
| Move And Rename Class | 1 | ||
| Move And Rename Class org.apache.flink.streaming.connectors.kafka.KafkaTopology.MyKafkaSink moved and renamed to org.apache.flink.streaming.connectors.rabbitmq.RMQTopology.StringToByteSerializer | From | To | |
| Extract Superclass | 1 | ||
| Extract Superclass org.apache.flink.streaming.api.function.source.RichParallelSourceFunction from classes [org.apache.flink.streaming.api.function.source.GenSequenceFunction, org.apache.flink.streaming.connectors.kafka.KafkaSource, org.apache.flink.streaming.connectors.rabbitmq.RMQSource, org.apache.flink.streaming.connectors.twitter.TwitterSource] | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute outTuple : OUT to out : OUT in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource | From | To | |
| Rename Attribute numThreads : int to scheme : DeserializationScheme<OUT> in class org.apache.flink.streaming.connectors.kafka.KafkaSource | From | To | |
| Extract Variable | 1 | ||
| Extract Variable dop : int in method private addSource(function SourceFunction<OUT>, outTypeInfo TypeInformation<OUT>, sourceName String) : DataStreamSource<OUT> from class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Extract Interface | 1 | ||
| Extract Interface org.apache.flink.streaming.api.function.source.ParallelSourceFunction from classes [org.apache.flink.streaming.connectors.flume.FlumeSource] | From | To | |
| Extract Method | 3 | ||
| Extract Method private addSource(function SourceFunction<OUT>, outTypeInfo TypeInformation<OUT>, sourceName String) : DataStreamSource<OUT> extracted from public fromElements(data OUT...) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Extract Method private addSource(function SourceFunction<OUT>, outTypeInfo TypeInformation<OUT>, sourceName String) : DataStreamSource<OUT> extracted from public fromCollection(data Collection<OUT>) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Extract Method private addSource(function SourceFunction<OUT>, outTypeInfo TypeInformation<OUT>, sourceName String) : DataStreamSource<OUT> extracted from public addSource(function SourceFunction<OUT>, outTypeInfo TypeInformation<OUT>) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type numThreads : int to scheme : DeserializationScheme<OUT> in class org.apache.flink.streaming.connectors.kafka.KafkaSource | From | To | |
| Rename Parameter | 4 | ||
| Rename Parameter numThreads : int to deserializationScheme : DeserializationScheme<OUT> in method public KafkaSource(zkQuorum String, groupId String, topicId String, deserializationScheme DeserializationScheme<OUT>) in class org.apache.flink.streaming.connectors.kafka.KafkaSource | From | To | |
| Rename Parameter value : IN to next : IN in method public invoke(next IN) : void in class org.apache.flink.streaming.connectors.kafka.KafkaSink | From | To | |
| Rename Parameter tuple : String to element : String in method public serialize(element String) : byte[] in class org.apache.flink.streaming.connectors.flume.FlumeTopology.StringToByteSerializer | From | To | |
| Rename Parameter tuple : String to element : String in method public serialize(element String) : byte[] in class org.apache.flink.streaming.connectors.rabbitmq.RMQTopology.StringToByteSerializer | From | To |