|
Change Parameter Type inputSerDe : SerDe to inputSerDe : List<SerDe> in method public JavaInstance(config JavaInstanceConfig, clsLoader ClassLoader, inputSerDe List<SerDe>, outputSerDe SerDe) in class org.apache.pulsar.functions.runtime.instance.JavaInstance |
From |
To |
|
Change Parameter Type msg : Message to msg : InputMessage in method private processResult(msg InputMessage, result JavaExecutionResult, processAt long) : void in class org.apache.pulsar.functions.runtime.instance.JavaInstanceRunnable |
From |
To |
|
Change Parameter Type inputSerDe : SerDe to inputSerDe : List<SerDe> in method private computeInputAndOutputTypesAndVerifySerDe(inputSerDe List<SerDe>, outputSerDe SerDe) : void in class org.apache.pulsar.functions.runtime.instance.JavaInstance |
From |
To |
|
Change Parameter Type inputSerDe : SerDe to inputSerDe : List<SerDe> in method package JavaInstance(config JavaInstanceConfig, object Object, inputSerDe List<SerDe>, outputSerDe SerDe) in class org.apache.pulsar.functions.runtime.instance.JavaInstance |
From |
To |