0f84222deff90acbb5bab99cc56e9e6f673ad7ef
Files Diff
- Added: 0
- Removed: 0
- Renamed: 0
- Modified: 4
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Change Parameter Type | 2 | ||
| Change Parameter Type consumeFunction : Function<Record<String>,CompletableFuture<Void>> to consumeFunction : Consumer<Record<String>> in method public setConsumer(consumeFunction Consumer<Record<String>>) : void in class org.apache.pulsar.io.twitter.TwitterFireHose | From | To | |
| Change Parameter Type consumeFunction : Function<Record<byte[]>,CompletableFuture<Void>> to consumeFunction : Consumer<Record<byte[]>> in method public RabbitMQConsumer(consumeFunction Consumer<Record<byte[]>>, channel Channel) in class org.apache.pulsar.io.rabbitmq.RabbitMQSource.RabbitMQConsumer | From | To | |
| Change Attribute Type | 4 | ||
| Change Attribute Type consumeFunction : Function<Record<String>,CompletableFuture<Void>> to consumeFunction : Consumer<Record<String>> in class org.apache.pulsar.io.twitter.TwitterFireHose | From | To | |
| Change Attribute Type consumer : Function<Record<byte[]>,CompletableFuture<Void>> to consumer : Consumer<Record<byte[]>> in class org.apache.pulsar.io.rabbitmq.RabbitMQSource | From | To | |
| Change Attribute Type consumeFunction : Function<Record<V>,CompletableFuture<Void>> to consumeFunction : Consumer<Record<V>> in class org.apache.pulsar.io.kafka.KafkaSource | From | To | |
| Change Attribute Type consumeFunction : Function<Record<byte[]>,CompletableFuture<Void>> to consumeFunction : Consumer<Record<byte[]>> in class org.apache.pulsar.io.rabbitmq.RabbitMQSource.RabbitMQConsumer | From | To |