|
Change Parameter Type srcTopicPartition : int to srcTopicPartition : String in method public closeProducer(srcTopicName String, srcTopicPartition String) : void in class org.apache.pulsar.functions.instance.producers.Producers |
From |
To |
|
Change Parameter Type srcTopicPartition : int to srcTopicPartition : String in method public getProducer(srcTopicName String, srcTopicPartition String) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.Producers |
From |
To |
|
Change Parameter Type srcTopicPartition : int to srcTopicPartition : String in method public getProducer(srcTopicName String, srcTopicPartition String) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Change Parameter Type srcTopicPartition : int to srcTopicPartition : String in method package makeProducerName(srcTopicName String, srcTopicPartition String) : String in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Change Parameter Type pulsarConfig : PulsarConfig to pulsarConfig : PulsarSourceConfig in method public PulsarSource(pulsarClient PulsarClient, pulsarConfig PulsarSourceConfig) in class org.apache.pulsar.functions.source.PulsarSource |
From |
To |
|
Change Parameter Type srcTopicPartition : int to srcTopicPartition : String in method public closeProducer(srcTopicName String, srcTopicPartition String) : void in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Move Method public setupInput(inputType Class<?>) : void from class org.apache.pulsar.functions.instance.processors.MessageProcessorBase to public setupInput(inputType Class<?>) : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnable |
From |
To |
|
Move Method public testVoidOutputClasses() : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnableTest to public testVoidOutputClasses() : void from class org.apache.pulsar.functions.sink.PulsarSinkTest |
From |
To |
|
Move Method private setupSerDe(typeArgs Class<?>[], clsLoader ClassLoader) : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnable to package setupSerDe() : void from class org.apache.pulsar.functions.sink.PulsarSink |
From |
To |
|
Move Method public testDefaultSerDe() : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnableTest to public testDefaultSerDe() : void from class org.apache.pulsar.functions.sink.PulsarSinkTest |
From |
To |
|
Move Method public testInconsistentOutputType() : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnableTest to public testInconsistentOutputType() : void from class org.apache.pulsar.functions.sink.PulsarSinkTest |
From |
To |
|
Move Method public testExplicitDefaultSerDe() : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnableTest to public testExplicitDefaultSerDe() : void from class org.apache.pulsar.functions.sink.PulsarSinkTest |
From |
To |
|
Change Variable Type pulsarConfig : PulsarConfig to pulsarConfig : PulsarSourceConfig in method public testInconsistentInputType() : void in class org.apache.pulsar.functions.source.PulsarSourceTest |
From |
To |
|
Change Variable Type pulsarConfig : PulsarConfig to pulsarConfig : PulsarSourceConfig in method public testVoidInputClasses() : void in class org.apache.pulsar.functions.source.PulsarSourceTest |
From |
To |
|
Change Variable Type pulsarConfig : PulsarConfig to pulsarConfig : PulsarSourceConfig in method private getPulsarConfigs() : PulsarSourceConfig in class org.apache.pulsar.functions.source.PulsarSourceTest |
From |
To |
|
Change Variable Type producerMap : IntObjectMap<Producer<byte[]>> to producerMap : Map<String,Producer<byte[]>> in method public close() : void in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Change Variable Type producerMap : IntObjectMap<Producer<byte[]>> to producerMap : Map<String,Producer<byte[]>> in method public getProducer(srcTopicName String, srcTopicPartition String) : Producer<byte[]> in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Change Variable Type producerMap : IntObjectMap<Producer<byte[]>> to producerMap : Map<String,Producer<byte[]>> in method public closeProducer(srcTopicName String, srcTopicPartition String) : void in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |