|
Change Parameter Type instanceConfig : JavaInstanceConfig to instanceConfig : InstanceConfig in method package ProcessFunctionContainer(instanceConfig InstanceConfig, maxBufferedTuples int, javaInstanceJarFile String, logDirectory String, jarFile String, pulsarServiceUrl String) in class org.apache.pulsar.functions.runtime.container.ProcessFunctionContainer |
From |
To |
|
Change Parameter Type config : JavaInstanceConfig to config : InstanceConfig in method public JavaInstance(config InstanceConfig, clsLoader ClassLoader, pulsarClient PulsarClient, inputSerDe List<SerDe>, outputSerDe SerDe) in class org.apache.pulsar.functions.runtime.instance.JavaInstance |
From |
To |
|
Change Parameter Type instanceConfig : JavaInstanceConfig to instanceConfig : InstanceConfig in method package ThreadFunctionContainer(instanceConfig InstanceConfig, maxBufferedTuples int, fnCache FunctionCacheManager, threadGroup ThreadGroup, jarFile String, pulsarClient PulsarClient) in class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainer |
From |
To |
|
Change Parameter Type instanceConfig : JavaInstanceConfig to instanceConfig : InstanceConfig in method public createContainer(instanceConfig InstanceConfig, jarFile String) : ThreadFunctionContainer in class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainerFactory |
From |
To |
|
Change Parameter Type instanceConfig : JavaInstanceConfig to instanceConfig : InstanceConfig in method public createContainer(instanceConfig InstanceConfig, jarFile String) : ProcessFunctionContainer in class org.apache.pulsar.functions.runtime.container.ProcessFunctionContainerFactory |
From |
To |
|
Change Parameter Type config : JavaInstanceConfig to config : InstanceConfig in method package JavaInstance(config InstanceConfig, object Object, clsLoader ClassLoader, pulsarClient PulsarClient, inputSerDe List<SerDe>, outputSerDe SerDe) in class org.apache.pulsar.functions.runtime.instance.JavaInstance |
From |
To |
|
Change Parameter Type instanceConfig : JavaInstanceConfig to instanceConfig : InstanceConfig in method public JavaInstanceRunnable(instanceConfig InstanceConfig, maxBufferedTuples int, fnCache FunctionCacheManager, jarFile String, pulsarClient PulsarClient) in class org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable |
From |
To |
|
Change Parameter Type config : JavaInstanceConfig to config : InstanceConfig in method public ContextImpl(config InstanceConfig, logger Logger, client PulsarClient, classLoader ClassLoader) in class org.apache.pulsar.functions.runtime.instance.ContextImpl |
From |
To |
|
Change Variable Type config : JavaInstanceConfig to config : InstanceConfig in method package createJavaInstanceConfig() : InstanceConfig in class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainerTest |
From |
To |
|
Change Variable Type config : JavaInstanceConfig to config : InstanceConfig in method public testVoidInputClasses() : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceTest |
From |
To |
|
Change Variable Type config : JavaInstanceConfig to config : InstanceConfig in method public testInconsistentOutputType() : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceTest |
From |
To |
|
Change Variable Type javaInstanceConfig : JavaInstanceConfig to instanceConfig : InstanceConfig in method private createJavaInstanceConfig() : InstanceConfig in class org.apache.pulsar.functions.runtime.spawner.Spawner |
From |
To |
|
Change Variable Type config : JavaInstanceConfig to config : InstanceConfig in method public testInconsistentInputType() : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceTest |
From |
To |
|
Change Variable Type config : JavaInstanceConfig to config : InstanceConfig in method public testUnsupportedClasses() : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceTest |
From |
To |
|
Change Variable Type config : JavaInstanceConfig to config : InstanceConfig in method public testLongRunningFunction() : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceTest |
From |
To |
|
Change Variable Type config : JavaInstanceConfig to config : InstanceConfig in method public testConstructor() : void in class org.apache.pulsar.functions.runtime.container.ProcessFunctionContainerTest |
From |
To |
|
Change Variable Type config : JavaInstanceConfig to config : InstanceConfig in method package createJavaInstanceConfig() : InstanceConfig in class org.apache.pulsar.functions.runtime.container.ProcessFunctionContainerTest |
From |
To |
|
Change Variable Type config : JavaInstanceConfig to config : InstanceConfig in method public testVoidOutputClasses() : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceTest |
From |
To |
|
Change Variable Type config : JavaInstanceConfig to config : InstanceConfig in method public testLambda() : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceTest |
From |
To |
|
Change Variable Type config : JavaInstanceConfig to config : InstanceConfig in method public testConstructor() : void in class org.apache.pulsar.functions.runtime.container.ThreadFunctionContainerTest |
From |
To |
|
Change Variable Type instanceConfig : JavaInstanceConfig to instanceConfig : InstanceConfig in method private createInstanceConfig() : InstanceConfig in class org.apache.pulsar.functions.runtime.instance.JavaInstanceTest |
From |
To |
|
Change Variable Type instanceConfig : JavaInstanceConfig to instanceConfig : InstanceConfig in method public start() : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceMain |
From |
To |