|
Rename Method public getSourceTopics() : Collection<String> renamed to public getInputTopics() : Collection<String> in class org.apache.pulsar.functions.api.Context |
From |
To |
|
Rename Method private startSourceConsumers() : void renamed to private startInputConsumer() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnable |
From |
To |
|
Rename Method public getSinkTopic() : String renamed to public getOutputTopic() : String in class org.apache.pulsar.functions.api.Context |
From |
To |
|
Rename Method public getSinkTopic() : String renamed to public getOutputTopic() : String in class org.apache.pulsar.functions.instance.ContextImpl |
From |
To |
|
Rename Method public getSourceTopics() : Collection<String> renamed to public getInputTopics() : Collection<String> in class org.apache.pulsar.functions.instance.ContextImpl |
From |
To |
|
Rename Method public testRegisterFunctionMissingSourceTopic() : void renamed to public testRegisterFunctionMissingInputTopic() : void in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |
|
Rename Method private startSinkProducer() : void renamed to private startOutputProducer() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnable |
From |
To |
|
Rename Method public testCreateWithoutSinkTopic() : void renamed to public testCreateWithoutOutputTopic() : void in class org.apache.pulsar.admin.cli.CmdFunctionsTest |
From |
To |
|
Rename Variable sourceTopics : String[] to inputTopics : String[] in method public start() : void in class org.apache.pulsar.functions.runtime.JavaInstanceMain |
From |
To |
|
Rename Variable sinkTopicName : String to inputTopicName : String in method public testCreateWithoutFunctionName() : void in class org.apache.pulsar.admin.cli.CmdFunctionsTest |
From |
To |
|
Rename Variable sourceTopicName : String to inputTopicName : String in method public testCreateWithoutOutputTopic() : void in class org.apache.pulsar.admin.cli.CmdFunctionsTest |
From |
To |
|
Rename Variable sourceTopicName : String to inputTopicName : String in method public testUpdateFunction() : void in class org.apache.pulsar.admin.cli.CmdFunctionsTest |
From |
To |
|
Rename Variable sourceTopicName : String to inputTopicName : String in method public testCreateFunction() : void in class org.apache.pulsar.admin.cli.CmdFunctionsTest |
From |
To |
|
Rename Variable sourceTopicName : String to outputTopicName : String in method public testCreateWithoutFunctionName() : void in class org.apache.pulsar.admin.cli.CmdFunctionsTest |
From |
To |
|
Rename Variable sinkTopicName : String to outputTopicName : String in method public testUpdateFunction() : void in class org.apache.pulsar.admin.cli.CmdFunctionsTest |
From |
To |
|
Rename Variable sinkTopicName : String to outputTopicName : String in method public testCreateFunction() : void in class org.apache.pulsar.admin.cli.CmdFunctionsTest |
From |
To |
|
Rename Variable sourceTopicString : String to inputTopicString : String in method private composeArgs(instanceConfig InstanceConfig, instanceFile String, logDirectory String, codeFile String, pulsarServiceUrl String) : List<String> in class org.apache.pulsar.functions.runtime.ProcessRuntime |
From |
To |
|
Rename Variable sinkTopicName : String to inputTopicName : String in method public testCreateWithoutTenant() : void in class org.apache.pulsar.admin.cli.CmdFunctionsTest |
From |
To |
|
Rename Variable sourceTopicName : String to outputTopicName : String in method public testCreateWithoutTenant() : void in class org.apache.pulsar.admin.cli.CmdFunctionsTest |
From |
To |
|
Rename Variable sourceTopic : String to inputTopic : String in method public start() : void in class org.apache.pulsar.functions.runtime.JavaInstanceMain |
From |
To |
|
Rename Variable sourceTopicName : String to outputTopicName : String in method public testCreateWithoutNamespace() : void in class org.apache.pulsar.admin.cli.CmdFunctionsTest |
From |
To |
|
Rename Variable sinkTopicName : String to inputTopicName : String in method public testCreateWithoutNamespace() : void in class org.apache.pulsar.admin.cli.CmdFunctionsTest |
From |
To |
|
Rename Attribute sinkProducer : Producers to outputProducer : Producers in class org.apache.pulsar.functions.instance.JavaInstanceRunnable |
From |
To |
|
Rename Attribute sinkTopicName : String to outputTopicName : String in class org.apache.pulsar.functions.runtime.JavaInstanceMain |
From |
To |
|
Rename Attribute sourceTopic : String to inputTopic : String in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |
|
Rename Attribute TEST_SINK_TOPIC : String to TEST_OUTPUT_TOPIC : String in class org.apache.pulsar.functions.instance.producers.SimpleOneOutputTopicProducersTest |
From |
To |
|
Rename Attribute defaultSerdeSourceTopics : String to defaultSerdeInputTopics : String in class org.apache.pulsar.functions.runtime.JavaInstanceMain |
From |
To |
|
Rename Attribute TEST_SINK_TOPIC : String to TEST_OUTPUT_TOPIC : String in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOutputTopicProducersTest |
From |
To |
|
Rename Attribute sourceTopicsToResubscribe : LinkedList<String> to inputTopicsToResubscribe : LinkedList<String> in class org.apache.pulsar.functions.instance.JavaInstanceRunnable |
From |
To |
|
Rename Attribute sinkTopic : String to outputTopic : String in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |
|
Rename Attribute customSerdeSourceTopics : String to customSerdeInputTopics : String in class org.apache.pulsar.functions.runtime.JavaInstanceMain |
From |
To |
|
Rename Attribute sourceConsumers : Map<String,Consumer> to inputConsumers : Map<String,Consumer> in class org.apache.pulsar.functions.instance.JavaInstanceRunnable |
From |
To |
|
Rename Attribute sinkTopic : String to outputTopic : String in class org.apache.pulsar.functions.instance.producers.AbstractOneOuputTopicProducers |
From |
To |
|
Rename Attribute sourceConsumers : Map<String,Consumer> to inputConsumers : Map<String,Consumer> in class org.apache.pulsar.functions.instance.ContextImpl |
From |
To |
|
Rename Parameter sinkTopic : String to outputTopic : String in method public MultiConsumersOneOuputTopicProducers(client PulsarClient, outputTopic String) in class org.apache.pulsar.functions.instance.producers.MultiConsumersOneOuputTopicProducers |
From |
To |
|
Rename Parameter sourceTopic : String to inputTopic : String in method private testRegisterFunctionMissingArguments(tenant String, namespace String, function String, inputStream InputStream, details FormDataContentDisposition, outputTopic String, inputTopic String, inputSerdeClassName String, outputSerdeClassName String, className String, parallelism Integer, missingFieldName String) : void in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |
|
Rename Parameter sinkTopic : String to outputTopic : String in method package AbstractOneOuputTopicProducers(client PulsarClient, outputTopic String) in class org.apache.pulsar.functions.instance.producers.AbstractOneOuputTopicProducers |
From |
To |
|
Rename Parameter sourceConsumers : Map<String,Consumer> to inputConsumers : Map<String,Consumer> in method public JavaInstance(config InstanceConfig, userClassObject Object, clsLoader ClassLoader, pulsarClient PulsarClient, inputConsumers Map<String,Consumer>) in class org.apache.pulsar.functions.instance.JavaInstance |
From |
To |
|
Rename Parameter sinkTopic : String to outputTopic : String in method private testRegisterFunctionMissingArguments(tenant String, namespace String, function String, inputStream InputStream, details FormDataContentDisposition, outputTopic String, inputTopic String, inputSerdeClassName String, outputSerdeClassName String, className String, parallelism Integer, missingFieldName String) : void in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |
|
Rename Parameter sinkTopic : String to outputTopic : String in method public SimpleOneOuputTopicProducers(client PulsarClient, outputTopic String) in class org.apache.pulsar.functions.instance.producers.SimpleOneOuputTopicProducers |
From |
To |
|
Rename Parameter sourceConsumers : Map<String,Consumer> to inputConsumers : Map<String,Consumer> in method public ContextImpl(config InstanceConfig, logger Logger, client PulsarClient, classLoader ClassLoader, inputConsumers Map<String,Consumer>) in class org.apache.pulsar.functions.instance.ContextImpl |
From |
To |
|
Rename Parameter sinkTopic : String to outputTopic : String in method private testUpdateFunctionMissingArguments(tenant String, namespace String, function String, inputStream InputStream, details FormDataContentDisposition, outputTopic String, inputTopic String, inputSerdeClassName String, outputSerdeClassName String, className String, parallelism Integer, missingFieldName String) : void in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |
|
Rename Parameter sourceTopic : String to inputTopic : String in method private testUpdateFunctionMissingArguments(tenant String, namespace String, function String, inputStream InputStream, details FormDataContentDisposition, outputTopic String, inputTopic String, inputSerdeClassName String, outputSerdeClassName String, className String, parallelism Integer, missingFieldName String) : void in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |