|
Change Parameter Type consumer : Function<Message<T>,CompletableFuture<Void>> to consumer : Function<Record<T>,CompletableFuture<Void>> in method public setConsumer(consumer Function<Record<T>,CompletableFuture<Void>>) : void in class org.apache.pulsar.connect.core.PushSource |
From |
To |
|
Change Parameter Type config : Map<String,String> to config : Map<String,Object> in method public open(config Map<String,Object>) : void in class org.apache.pulsar.connect.twitter.TwitterFireHose |
From |
To |
|
Change Parameter Type message : Message<KeyValue<K,V>> to message : KeyValue<K,V> in method public write(message KeyValue<K,V>) : CompletableFuture<Void> in class org.apache.pulsar.connect.kafka.KafkaSink |
From |
To |
|
Change Parameter Type tuple : Message<KeyValue<K,V>> to record : KeyValue<K,V> in method public write(record KeyValue<K,V>) : CompletableFuture<Void> in class org.apache.pulsar.connect.cassandra.CassandraSink |
From |
To |
|
Change Parameter Type consumeFunction : Function<Message<V>,CompletableFuture<Void>> to consumeFunction : Function<Record<V>,CompletableFuture<Void>> in method public setConsumer(consumeFunction Function<Record<V>,CompletableFuture<Void>>) : void in class org.apache.pulsar.connect.kafka.KafkaSource |
From |
To |
|
Change Parameter Type consumeFunction : Function<Message<String>,CompletableFuture<Void>> to consumeFunction : Function<Record<String>,CompletableFuture<Void>> in method public setConsumer(consumeFunction Function<Record<String>,CompletableFuture<Void>>) : void in class org.apache.pulsar.connect.twitter.TwitterFireHose |
From |
To |
|
Change Parameter Type tuple : Message<KeyValue<K,V>> to record : KeyValue<K,V> in method public write(record KeyValue<K,V>) : CompletableFuture<Void> in class org.apache.pulsar.connect.aerospike.AerospikeSink |
From |
To |
|
Change Parameter Type map : Map<String,String> to map : Map<String,Object> in method public load(map Map<String,Object>) : AerospikeSinkConfig in class org.apache.pulsar.connect.aerospike.AerospikeSinkConfig |
From |
To |
|
Change Parameter Type map : Map<String,String> to map : Map<String,Object> in method public load(map Map<String,Object>) : KafkaSourceConfig in class org.apache.pulsar.connect.kafka.KafkaSourceConfig |
From |
To |
|
Change Parameter Type config : Map<String,String> to config : Map<String,Object> in method public open(config Map<String,Object>) : void in class org.apache.pulsar.connect.kafka.KafkaSink |
From |
To |
|
Change Parameter Type map : Map<String,String> to map : Map<String,Object> in method public load(map Map<String,Object>) : RabbitMQConfig in class org.apache.pulsar.connect.rabbitmq.RabbitMQConfig |
From |
To |
|
Change Parameter Type config : Map<String,String> to config : Map<String,Object> in method public open(config Map<String,Object>) : void in class org.apache.pulsar.connect.cassandra.CassandraSink |
From |
To |
|
Change Parameter Type config : Map<String,String> to config : Map<String,Object> in method public open(config Map<String,Object>) : void in class org.apache.pulsar.connect.kafka.KafkaSource |
From |
To |
|
Change Parameter Type config : Map<String,String> to config : Map<String,Object> in method public open(config Map<String,Object>) : void in class org.apache.pulsar.connect.rabbitmq.RabbitMQSource |
From |
To |
|
Change Parameter Type config : Map<String,String> to config : Map<String,Object> in method public open(config Map<String,Object>) : void in class org.apache.pulsar.connect.core.Sink |
From |
To |
|
Change Parameter Type map : Map<String,String> to map : Map<String,Object> in method public load(map Map<String,Object>) : CassandraSinkConfig in class org.apache.pulsar.connect.cassandra.CassandraSinkConfig |
From |
To |
|
Change Parameter Type config : Map<String,String> to config : Map<String,Object> in method public open(config Map<String,Object>) : void in class org.apache.pulsar.connect.core.PushSource |
From |
To |
|
Change Parameter Type consumeFunction : Function<Message<byte[]>,CompletableFuture<Void>> to consumeFunction : Function<Record<byte[]>,CompletableFuture<Void>> in method public setConsumer(consumeFunction Function<Record<byte[]>,CompletableFuture<Void>>) : void in class org.apache.pulsar.connect.rabbitmq.RabbitMQSource |
From |
To |
|
Change Parameter Type map : Map<String,String> to map : Map<String,Object> in method public load(map Map<String,Object>) : TwitterFireHoseConfig in class org.apache.pulsar.connect.twitter.TwitterFireHoseConfig |
From |
To |
|
Change Parameter Type config : Map<String,String> to config : Map<String,Object> in method public open(config Map<String,Object>) : void in class org.apache.pulsar.connect.aerospike.AerospikeSink |
From |
To |
|
Change Parameter Type consumeFunction : Function<Message<byte[]>,CompletableFuture<Void>> to consumeFunction : Function<Record<byte[]>,CompletableFuture<Void>> in method public RabbitMQConsumer(consumeFunction Function<Record<byte[]>,CompletableFuture<Void>>, channel Channel) in class org.apache.pulsar.connect.rabbitmq.RabbitMQSource.RabbitMQConsumer |
From |
To |
|
Change Parameter Type map : Map<String,String> to map : Map<String,Object> in method public load(map Map<String,Object>) : KafkaSinkConfig in class org.apache.pulsar.connect.kafka.KafkaSinkConfig |
From |
To |