4101168fbf5689af0eac37e1fc03195778f544d5
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 1
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 1 | ||
| Change Parameter Type producer : Producer<byte[]> to producerConfig : Map<String,Object> in method public FlinkPulsarProducer(serviceUrl String, defaultTopicName String, serializationSchema SerializationSchema<IN>, keyExtractor PulsarKeyExtractor<IN>, producerConfig Map<String,Object>) in class org.apache.flink.streaming.connectors.pulsar.FlinkPulsarProducer | From | To | |
| Extract Variable | 1 | ||
| Extract Variable producerBuilder : ProducerBuilder<byte[]> in method private createProducer() : Producer<byte[]> from class org.apache.flink.streaming.connectors.pulsar.FlinkPulsarProducer | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter producer : Producer<byte[]> to producerConfig : Map<String,Object> in method public FlinkPulsarProducer(serviceUrl String, defaultTopicName String, serializationSchema SerializationSchema<IN>, keyExtractor PulsarKeyExtractor<IN>, producerConfig Map<String,Object>) in class org.apache.flink.streaming.connectors.pulsar.FlinkPulsarProducer | From | To |