|
Change Parameter Type runtime : FunctionConfig.Runtime to runtime : FunctionDetails.Runtime in method package createFunctionDetails(runtime FunctionDetails.Runtime) : FunctionDetails in class org.apache.pulsar.functions.runtime.ProcessRuntimeTest |
From |
To |
|
Change Parameter Type functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method private createMetric(functionDetails Function.FunctionDetails, metric String, value double) : String in class org.apache.pulsar.functions.metrics.sink.PrometheusSinkTests |
From |
To |
|
Change Parameter Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public createFunction(functionDetails FunctionDetails, fileName String) : void in class org.apache.pulsar.client.admin.internal.FunctionsImpl |
From |
To |
|
Change Parameter Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method package EffectivelyOnceProcessor(client PulsarClient, functionDetails FunctionDetails, processQueue LinkedBlockingDeque<InputMessage>) in class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor |
From |
To |
|
Change Parameter Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public updateFunction(functionDetails FunctionDetails, fileName String) : void in class org.apache.pulsar.client.admin.Functions |
From |
To |
|
Change Parameter Type functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method public processRecord(record MetricsData, functionDetails Function.FunctionDetails) : void in class org.apache.pulsar.functions.metrics.MetricsSink |
From |
To |
|
Change Parameter Type functionConfig : Function.FunctionConfig to FunctionDetails : Function.FunctionDetails in method public processRecord(record InstanceCommunication.MetricsData, FunctionDetails Function.FunctionDetails) : void in class org.apache.pulsar.functions.metrics.sink.FileSink |
From |
To |
|
Change Parameter Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method protected MessageProcessorBase(client PulsarClient, functionDetails FunctionDetails, subType SubscriptionType, processQueue LinkedBlockingDeque<InputMessage>) in class org.apache.pulsar.functions.instance.processors.MessageProcessorBase |
From |
To |
|
Change Parameter Type functionConfigBuilder : FunctionConfig.Builder to functionConfig : FunctionConfig in method private parseFullyQualifiedFunctionName(fqfn String, functionConfig FunctionConfig) : void in class org.apache.pulsar.admin.cli.CmdFunctions |
From |
To |
|
Change Parameter Type functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method private containsFunctionMetaData(functionDetails Function.FunctionDetails) : boolean in class org.apache.pulsar.functions.worker.FunctionMetaDataManager |
From |
To |
|
Change Parameter Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method package AtLeastOnceProcessor(client PulsarClient, functionDetails FunctionDetails, subType SubscriptionType, processQueue LinkedBlockingDeque<InputMessage>) in class org.apache.pulsar.functions.instance.processors.AtLeastOnceProcessor |
From |
To |
|
Change Parameter Type functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method public processRecord(record MetricsData, functionDetails Function.FunctionDetails) : void in class org.apache.pulsar.functions.metrics.sink.PrometheusSink |
From |
To |
|
Change Parameter Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public create(client PulsarClient, functionDetails FunctionDetails, processQeueue LinkedBlockingDeque<InputMessage>) : MessageProcessor in class org.apache.pulsar.functions.instance.processors.MessageProcessor |
From |
To |
|
Change Parameter Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method package AtMostOnceProcessor(client PulsarClient, functionDetails FunctionDetails, subType SubscriptionType, processQueue LinkedBlockingDeque<InputMessage>) in class org.apache.pulsar.functions.instance.processors.AtMostOnceProcessor |
From |
To |
|
Change Parameter Type runtime : FunctionConfig.Runtime to runtime : FunctionDetails.Runtime in method package createJavaInstanceConfig(runtime FunctionDetails.Runtime) : InstanceConfig in class org.apache.pulsar.functions.runtime.ProcessRuntimeTest |
From |
To |
|
Change Parameter Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public updateFunction(functionDetails FunctionDetails, fileName String) : void in class org.apache.pulsar.client.admin.internal.FunctionsImpl |
From |
To |
|
Change Parameter Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public createFunction(functionDetails FunctionDetails, fileName String) : void in class org.apache.pulsar.client.admin.Functions |
From |
To |
|
Rename Variable functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method public testMetricsGrouping() : void in class org.apache.pulsar.functions.metrics.sink.PrometheusSinkTests |
From |
To |
|
Rename Variable functionConfig : FunctionConfig to functionDetails : FunctionDetails in method private updateDefaultFunction() : Response in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |
|
Rename Variable functionConfigBuilder : Function.FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method private convert(functionConfig FunctionConfig) : FunctionDetails in class org.apache.pulsar.admin.cli.CmdFunctions |
From |
To |
|
Rename Variable functionConfigJson : String to functionDetailsJson : String in method public getFunctionInfo(tenant String, namespace String, functionName String) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Rename Variable functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public start() : void in class org.apache.pulsar.functions.runtime.JavaInstanceMain |
From |
To |
|
Rename Variable functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method public start() : void in class org.apache.pulsar.functions.runtime.JavaInstanceMain |
From |
To |
|
Rename Variable newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testEffectivelyOnceProcessing() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Rename Variable functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method package setFunctionMetaData(functionMetaData FunctionMetaData) : void in class org.apache.pulsar.functions.worker.FunctionMetaDataManager |
From |
To |
|
Rename Variable functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public testGetFunctionSuccess() : void in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |
|
Rename Variable newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testEffectivelyOnceProcessingFailures() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Rename Variable newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testVoidFunction() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Rename Variable functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public updateFunction(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Rename Variable functionConfigJson : String to functionDetailsJson : String in method public getFunctionInstanceStatus(tenant String, namespace String, functionName String, instanceId String) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Rename Variable functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public registerFunction(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Rename Variable functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method public testResponse() : void in class org.apache.pulsar.functions.metrics.sink.PrometheusSinkTests |
From |
To |
|
Rename Variable functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method private createInstanceConfig() : InstanceConfig in class org.apache.pulsar.functions.instance.JavaInstanceTest |
From |
To |
|
Rename Variable newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testAtLeastOnceProcessing() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Rename Variable functionConfig : FunctionConfig to functionDetails : FunctionDetails in method private registerDefaultFunction() : Response in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |
|
Rename Variable functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder 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 Variable newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testAtLeastOnceProcessingFailures() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Rename Variable functionConfig : FunctionConfig to functionDetails : FunctionDetails 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 Variable functionConfig : FunctionConfig to functionDetails : FunctionDetails in method private validateUpdateRequestParams(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : FunctionDetails in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Rename Variable functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method package createFunctionDetails(runtime FunctionDetails.Runtime) : FunctionDetails in class org.apache.pulsar.functions.runtime.ProcessRuntimeTest |
From |
To |
|
Rename Variable functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method private validateUpdateRequestParams(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : FunctionDetails in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Rename Variable functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public triggerFunction(tenant String, namespace String, functionName String, input String, uploadedInputStream InputStream) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Rename Variable functionConfigJson : String to functionDetailsJson : String in method public getFunctionStatus(tenant String, namespace String, functionName String) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Rename Variable functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method private isRequestOutdated(serviceRequest Request.ServiceRequest) : boolean in class org.apache.pulsar.functions.worker.FunctionMetaDataManager |
From |
To |
|
Rename Variable newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testAtMostOnceProcessing() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Rename Variable functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method public getFunction(tenant String, namespace String, function String) : FunctionDetails in class org.apache.pulsar.client.admin.internal.FunctionsImpl |
From |
To |
|
Rename Variable newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testAtMostOnceProcessingFailures() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Rename Variable functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method private createInstanceConfig(addCustom boolean, outputSerde String) : InstanceConfig in class org.apache.pulsar.functions.instance.JavaInstanceRunnableTest |
From |
To |
|
Rename Variable functionConfig : FunctionConfig to functionDetails : FunctionDetails 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 Variable functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder 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 |
|
Change Variable Type functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method public getFunction(tenant String, namespace String, function String) : FunctionDetails in class org.apache.pulsar.client.admin.internal.FunctionsImpl |
From |
To |
|
Change Variable Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public testGetFunctionSuccess() : void in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |
|
Change Variable Type newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testVoidFunction() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Change Variable Type fc : FunctionConfig to fc : FunctionDetails in method public testDefaultProcessingGuarantee() : void in class org.apache.pulsar.functions.proto.FunctionDetailsTest |
From |
To |
|
Change Variable Type functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method private createInstanceConfig(addCustom boolean, outputSerde String) : InstanceConfig in class org.apache.pulsar.functions.instance.JavaInstanceRunnableTest |
From |
To |
|
Change Variable Type functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method public testResponse() : void in class org.apache.pulsar.functions.metrics.sink.PrometheusSinkTests |
From |
To |
|
Change Variable Type functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method private createInstanceConfig() : InstanceConfig in class org.apache.pulsar.functions.instance.JavaInstanceTest |
From |
To |
|
Change Variable Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method private registerDefaultFunction() : Response in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |
|
Change Variable Type fnSubType : FunctionConfig.SubscriptionType to fnSubType : FunctionDetails.SubscriptionType in method public create(client PulsarClient, functionDetails FunctionDetails, processQeueue LinkedBlockingDeque<InputMessage>) : MessageProcessor in class org.apache.pulsar.functions.instance.processors.MessageProcessor |
From |
To |
|
Change Variable Type functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder 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 |
|
Change Variable Type functionConfig : FunctionConfig to functionDetails : FunctionDetails 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 |
|
Change Variable Type functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method private validateUpdateRequestParams(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : FunctionDetails in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Change Variable Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method private validateUpdateRequestParams(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : FunctionDetails in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Change Variable Type functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method package createFunctionDetails(runtime FunctionDetails.Runtime) : FunctionDetails in class org.apache.pulsar.functions.runtime.ProcessRuntimeTest |
From |
To |
|
Change Variable Type functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method public testMetricsGrouping() : void in class org.apache.pulsar.functions.metrics.sink.PrometheusSinkTests |
From |
To |
|
Change Variable Type functionConfigBuilder : Function.FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method private convert(functionConfig FunctionConfig) : FunctionDetails in class org.apache.pulsar.admin.cli.CmdFunctions |
From |
To |
|
Change Variable Type functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method private isRequestOutdated(serviceRequest Request.ServiceRequest) : boolean in class org.apache.pulsar.functions.worker.FunctionMetaDataManager |
From |
To |
|
Change Variable Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public start() : void in class org.apache.pulsar.functions.runtime.JavaInstanceMain |
From |
To |
|
Change Variable Type newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testAtMostOnceProcessing() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Change Variable Type functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder in method public start() : void in class org.apache.pulsar.functions.runtime.JavaInstanceMain |
From |
To |
|
Change Variable Type newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testEffectivelyOnceProcessing() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Change Variable Type newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testAtMostOnceProcessingFailures() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Change Variable Type functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method package setFunctionMetaData(functionMetaData FunctionMetaData) : void in class org.apache.pulsar.functions.worker.FunctionMetaDataManager |
From |
To |
|
Change Variable Type newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testEffectivelyOnceProcessingFailures() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Change Variable Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public updateFunction(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Change Variable Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public registerFunction(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Change Variable Type newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testAtLeastOnceProcessing() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Change Variable Type newFnConfig : FunctionConfig to newFunctionDetails : FunctionDetails in method public testAtLeastOnceProcessingFailures() : void in class org.apache.pulsar.functions.instance.JavaInstanceRunnableProcessTest |
From |
To |
|
Change Variable Type functionConfigBuilder : FunctionConfig.Builder to functionDetailsBuilder : FunctionDetails.Builder 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 |
|
Change Variable Type functionConfig : FunctionConfig to functionDetails : FunctionDetails 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 |
|
Change Variable Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public triggerFunction(tenant String, namespace String, functionName String, input String, uploadedInputStream InputStream) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Change Variable Type functionConfig : FunctionConfig to functionDetails : FunctionDetails in method private updateDefaultFunction() : Response in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2ResourceTest |
From |
To |
|
Rename Parameter functionConfig : Function.FunctionConfig to FunctionDetails : Function.FunctionDetails in method public processRecord(record InstanceCommunication.MetricsData, FunctionDetails Function.FunctionDetails) : void in class org.apache.pulsar.functions.metrics.sink.FileSink |
From |
To |
|
Rename Parameter functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public createFunction(functionDetails FunctionDetails, fileName String) : void in class org.apache.pulsar.client.admin.internal.FunctionsImpl |
From |
To |
|
Rename Parameter functionConfig : FunctionConfig to functionDetails : FunctionDetails in method protected MessageProcessorBase(client PulsarClient, functionDetails FunctionDetails, subType SubscriptionType, processQueue LinkedBlockingDeque<InputMessage>) in class org.apache.pulsar.functions.instance.processors.MessageProcessorBase |
From |
To |
|
Rename Parameter functionConfigJson : String to functionDetailsJson : String in method public registerFunction(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : Response in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2Resource |
From |
To |
|
Rename Parameter functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method private containsFunctionMetaData(functionDetails Function.FunctionDetails) : boolean in class org.apache.pulsar.functions.worker.FunctionMetaDataManager |
From |
To |
|
Rename Parameter functionConfig : FunctionConfig to functionDetails : FunctionDetails in method package AtLeastOnceProcessor(client PulsarClient, functionDetails FunctionDetails, subType SubscriptionType, processQueue LinkedBlockingDeque<InputMessage>) in class org.apache.pulsar.functions.instance.processors.AtLeastOnceProcessor |
From |
To |
|
Rename Parameter functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method public processRecord(record MetricsData, functionDetails Function.FunctionDetails) : void in class org.apache.pulsar.functions.metrics.sink.PrometheusSink |
From |
To |
|
Rename Parameter functionConfig : FunctionConfig to functionDetails : FunctionDetails in method package AtMostOnceProcessor(client PulsarClient, functionDetails FunctionDetails, subType SubscriptionType, processQueue LinkedBlockingDeque<InputMessage>) in class org.apache.pulsar.functions.instance.processors.AtMostOnceProcessor |
From |
To |
|
Rename Parameter functionConfigJson : String to functionDetailsJson : String in method public registerFunction(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Rename Parameter functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public createFunction(functionDetails FunctionDetails, fileName String) : void in class org.apache.pulsar.client.admin.Functions |
From |
To |
|
Rename Parameter functionConfigJson : String to functionDetailsJson : String in method private validateUpdateRequestParams(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : FunctionDetails in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Rename Parameter functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method private createMetric(functionDetails Function.FunctionDetails, metric String, value double) : String in class org.apache.pulsar.functions.metrics.sink.PrometheusSinkTests |
From |
To |
|
Rename Parameter functionConfigJson : String to functionDetailsJson : String in method public updateFunction(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : Response in class org.apache.pulsar.functions.worker.rest.api.v2.FunctionApiV2Resource |
From |
To |
|
Rename Parameter functionConfigJson : String to functionDetailsJson : String in method public updateFunction(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : Response in class org.apache.pulsar.functions.worker.rest.api.FunctionsImpl |
From |
To |
|
Rename Parameter functionConfigBuilder : FunctionConfig.Builder to functionConfig : FunctionConfig in method private parseFullyQualifiedFunctionName(fqfn String, functionConfig FunctionConfig) : void in class org.apache.pulsar.admin.cli.CmdFunctions |
From |
To |
|
Rename Parameter functionConfigJson : String to functionDetailsJson : String in method public registerFunction(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : Response in class org.apache.pulsar.broker.admin.impl.FunctionsBase |
From |
To |
|
Rename Parameter functionConfig : FunctionConfig to functionDetails : FunctionDetails in method package EffectivelyOnceProcessor(client PulsarClient, functionDetails FunctionDetails, processQueue LinkedBlockingDeque<InputMessage>) in class org.apache.pulsar.functions.instance.processors.EffectivelyOnceProcessor |
From |
To |
|
Rename Parameter functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public create(client PulsarClient, functionDetails FunctionDetails, processQeueue LinkedBlockingDeque<InputMessage>) : MessageProcessor in class org.apache.pulsar.functions.instance.processors.MessageProcessor |
From |
To |
|
Rename Parameter functionConfigJson : String to functionDetailsJson : String in method public updateFunction(tenant String, namespace String, functionName String, uploadedInputStream InputStream, fileDetail FormDataContentDisposition, functionDetailsJson String) : Response in class org.apache.pulsar.broker.admin.impl.FunctionsBase |
From |
To |
|
Rename Parameter functionConfig : Function.FunctionConfig to functionDetails : Function.FunctionDetails in method public processRecord(record MetricsData, functionDetails Function.FunctionDetails) : void in class org.apache.pulsar.functions.metrics.MetricsSink |
From |
To |
|
Rename Parameter functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public updateFunction(functionDetails FunctionDetails, fileName String) : void in class org.apache.pulsar.client.admin.Functions |
From |
To |
|
Rename Parameter functionConfig : FunctionConfig to functionDetails : FunctionDetails in method public updateFunction(functionDetails FunctionDetails, fileName String) : void in class org.apache.pulsar.client.admin.internal.FunctionsImpl |
From |
To |