86a803366e1371ad5af539b74565e7b8ea102580
Files Diff
- Added: 2
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type hostName : String to rmqConnectionConfig : RMQConnectionConfig in method public RMQSource(rmqConnectionConfig RMQConnectionConfig, queueName String, usesCorrelationId boolean, deserializationSchema DeserializationSchema<OUT>) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource | From | To | |
| Change Parameter Type hostName : String to rmqConnectionConfig : RMQConnectionConfig in method public RMQSource(rmqConnectionConfig RMQConnectionConfig, queueName String, deserializationSchema DeserializationSchema<OUT>) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource | From | To | |
| Inline Method | 1 | ||
| Inline Method public initializeConnection() : void inlined to public open(config Configuration) : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQSink | From | To | |
| Move Attribute | 3 | ||
| Move Attribute private password : String from class org.apache.flink.streaming.connectors.rabbitmq.RMQSource to private password : String from class org.apache.flink.streaming.connectors.rabbitmq.common.RMQConnectionConfig | From | To | |
| Move Attribute private username : String from class org.apache.flink.streaming.connectors.rabbitmq.RMQSource to private username : String from class org.apache.flink.streaming.connectors.rabbitmq.common.RMQConnectionConfig | From | To | |
| Move Attribute private port : Integer from class org.apache.flink.streaming.connectors.rabbitmq.RMQSource to private port : Integer from class org.apache.flink.streaming.connectors.rabbitmq.common.RMQConnectionConfig | From | To | |
| Merge Parameter | 1 | ||
| Merge Parameter [hostName : String, port : Integer, username : String, password : String] to rmqConnectionConfig : RMQConnectionConfig in method public ConstructorTestClass(rmqConnectionConfig RMQConnectionConfig, queueName String, usesCorrelationId boolean, deserializationSchema DeserializationSchema<String>) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest.ConstructorTestClass | From | To | |
| Rename Attribute | 2 | ||
| Rename Attribute HOST_NAME : String to queueName : String in class org.apache.flink.streaming.connectors.rabbitmq.RMQSink | From | To | |
| Rename Attribute hostName : String to rmqConnectionConfig : RMQConnectionConfig in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource | From | To | |
| Change Attribute Type | 1 | ||
| Change Attribute Type hostName : String to rmqConnectionConfig : RMQConnectionConfig in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource | From | To | |
| Split Attribute | 1 | ||
| Split Attribute QUEUE_NAME : String to [queueName : String, rmqConnectionConfig : RMQConnectionConfig] in class org.apache.flink.streaming.connectors.rabbitmq.RMQSink | From | To | |
| Rename Parameter | 3 | ||
| Rename Parameter hostName : String to rmqConnectionConfig : RMQConnectionConfig in method public RMQSource(rmqConnectionConfig RMQConnectionConfig, queueName String, usesCorrelationId boolean, deserializationSchema DeserializationSchema<OUT>) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource | From | To | |
| Rename Parameter HOST_NAME : String to queueName : String in method public RMQSink(rmqConnectionConfig RMQConnectionConfig, queueName String, schema SerializationSchema<IN>) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSink | From | To | |
| Rename Parameter hostName : String to rmqConnectionConfig : RMQConnectionConfig in method public RMQSource(rmqConnectionConfig RMQConnectionConfig, queueName String, deserializationSchema DeserializationSchema<OUT>) in class org.apache.flink.streaming.connectors.rabbitmq.RMQSource | From | To |