54e957614c38fed69baf726fc86059e9b11384cb
Files Diff
- Added: 1
- Removed: 19
- Renamed: 0
- Modified: 20
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Move And Inline Method | 1 | ||
| Move And Inline Method public getType() : TypeInformation<OUT> moved from class org.apache.flink.streaming.connectors.ConnectorSource to class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment & inlined to private addSource(function SourceFunction<OUT>, sourceName String) : DataStreamSource<OUT> | From | To | |
| Change Return Type | 1 | ||
| Change Return Type HashMap<Integer,KafkaOffset> to long[] in method public snapshotState(checkpointId long, checkpointTimestamp long) : long[] in class org.apache.flink.streaming.connectors.kafka.api.persistent.PersistentKafkaSource | From | To | |
| Move Attribute | 1 | ||
| Move Attribute private zkClient : ZkClient from class org.apache.flink.streaming.connectors.kafka.api.simple.KafkaTopicUtils to private zkClient : ZkClient from class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To | |
| Move Class | 2 | ||
| Move Class org.apache.flink.streaming.connectors.kafka.api.simple.PersistentKafkaSource moved to org.apache.flink.streaming.connectors.kafka.api.persistent.PersistentKafkaSource | From | To | |
| Move Class org.apache.flink.streaming.connectors.kafka.api.simple.KafkaTopicUtils.KafkaZKStringSerializer moved to org.apache.flink.streaming.connectors.kafka.api.persistent.PersistentKafkaSource.KafkaZKStringSerializer | From | To | |
| Extract Method | 7 | ||
| Extract Method public tryExecute(see StreamExecutionEnvironment, name String) : void extracted from public customPartitioningTestTopology() : void in class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To | |
| Extract Method public tryExecute(see StreamExecutionEnvironment, name String) : void extracted from public regularKafkaSourceTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To | |
| Extract Method public tryExecute(see StreamExecutionEnvironment, name String) : void extracted from public simpleTestTopology() : void in class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To | |
| Extract Method public tryExecute(see StreamExecutionEnvironment, name String) : void extracted from public tupleTestTopology() : void in class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To | |
| Extract Method public tryExecute(see StreamExecutionEnvironment, name String) : void extracted from public bigRecordTestTopology() : void in class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To | |
| Extract Method public tryExecute(see StreamExecutionEnvironment, name String) : void extracted from public brokerFailureTest() : void in class org.apache.flink.streaming.connectors.kafka.KafkaITCase | From | To | |
| Extract Method public clear() : void extracted from public StreamGraph(environment StreamExecutionEnvironment) in class org.apache.flink.streaming.api.graph.StreamGraph | From | To | |
| Rename Parameter | 4 | ||
| Rename Parameter zookeeperAddress : String to brokerList : String in method public KafkaSink(brokerList String, topicId String, serializationSchema SerializationSchema<IN,byte[]>, partitioner Class<? extends SerializableKafkaPartitioner>) in class org.apache.flink.streaming.connectors.kafka.api.KafkaSink | From | To | |
| Rename Parameter zookeeperAddress : String to brokerList : String in method public KafkaSink(brokerList String, topicId String, serializationSchema SerializationSchema<IN,byte[]>, partitioner SerializableKafkaPartitioner) in class org.apache.flink.streaming.connectors.kafka.api.KafkaSink | From | To | |
| Rename Parameter zookeeperAddress : String to brokerList : String in method public KafkaSink(brokerList String, topicId String, producerConfig Properties, serializationSchema SerializationSchema<IN,byte[]>) in class org.apache.flink.streaming.connectors.kafka.api.KafkaSink | From | To | |
| Rename Parameter zookeeperAddress : String to brokerList : String in method public KafkaSink(brokerList String, topicId String, serializationSchema SerializationSchema<IN,byte[]>) in class org.apache.flink.streaming.connectors.kafka.api.KafkaSink | From | To |