|
Move And Rename Method public validateFileUrl(destPkgUrl String, downloadPkgDir String) : ClassLoader from class org.apache.pulsar.functions.worker.Utils to public extractClassLoader(destPkgUrl String) : ClassLoader from class org.apache.pulsar.functions.utils.Utils |
From |
To |
|
Move And Rename Method public extractNarClassloader(destPkgUrl String, downloadPkgDir String) : NarClassLoader from class org.apache.pulsar.functions.worker.Utils to public extractClassLoader(destPkgUrl String) : ClassLoader from class org.apache.pulsar.functions.utils.Utils |
From |
To |
|
Move And Rename Method public validateField(name String, o Object, classLoader ClassLoader) : void from class org.apache.pulsar.functions.utils.validation.ValidatorImpls.ImplementsClassValidator to public implementsClass(className String, klass Class<?>, classLoader ClassLoader) : void from class org.apache.pulsar.functions.utils.Utils |
From |
To |
|
Move Method private collectAllInputTopics(sinkConfig SinkConfig) : Collection<String> from class org.apache.pulsar.functions.utils.validation.ValidatorImpls.SinkConfigValidator to private collectAllInputTopics(sinkConfig SinkConfig) : Collection<String> from class org.apache.pulsar.functions.utils.SinkConfigUtils |
From |
To |
|
Move Method private verifyNoTopicClash(inputTopics Collection<String>, outputTopic String) : void from class org.apache.pulsar.functions.utils.validation.ValidatorImpls.FunctionConfigValidator to private verifyNoTopicClash(inputTopics Collection<String>, outputTopic String) : void from class org.apache.pulsar.functions.utils.FunctionConfigUtils |
From |
To |
|
Move Method public testValidateHttpFileUrl() : void from class org.apache.pulsar.functions.worker.UtilsTest to public testValidateHttpFileUrl() : void from class org.apache.pulsar.functions.utils.UtilsTest |
From |
To |
|
Move Method public testValidateLocalFileUrl() : void from class org.apache.pulsar.functions.worker.UtilsTest to public testValidateLocalFileUrl() : void from class org.apache.pulsar.functions.utils.UtilsTest |
From |
To |
|
Move Method public loadJar(jar File) : ClassLoader from class org.apache.pulsar.functions.utils.Reflections to public loadJar(jar File) : ClassLoader from class org.apache.pulsar.functions.utils.Utils |
From |
To |
|
Move Method private doPythonChecks(functionConfig FunctionConfig, name String) : void from class org.apache.pulsar.functions.utils.validation.ValidatorImpls.FunctionConfigValidator to private doPythonChecks(functionConfig FunctionConfig) : void from class org.apache.pulsar.functions.utils.FunctionConfigUtils |
From |
To |
|
Move Method private doJavaChecks(functionConfig FunctionConfig, name String, clsLoader ClassLoader) : void from class org.apache.pulsar.functions.utils.validation.ValidatorImpls.FunctionConfigValidator to private doJavaChecks(functionConfig FunctionConfig, clsLoader ClassLoader) : void from class org.apache.pulsar.functions.utils.FunctionConfigUtils |
From |
To |
|
Move Method private collectAllInputTopics(functionConfig FunctionConfig) : Collection<String> from class org.apache.pulsar.functions.utils.validation.ValidatorImpls.FunctionConfigValidator to private collectAllInputTopics(functionConfig FunctionConfig) : Collection<String> from class org.apache.pulsar.functions.utils.FunctionConfigUtils |
From |
To |
|
Change Variable Type archivePath : String to archivePath : Path in method protected validateSinkConfigs(sinkConfig SinkConfig) : void in class org.apache.pulsar.admin.cli.CmdSinks.SinkDetailsCommand |
From |
To |
|
Change Variable Type isArchivePathUrl : boolean to sourcePkgUrl : String in method protected validateSourceConfigs(sourceConfig SourceConfig) : void in class org.apache.pulsar.admin.cli.CmdSources.SourceDetailsCommand |
From |
To |
|
Change Variable Type archivePath : String to archivePath : Path in method protected validateSourceConfigs(sourceConfig SourceConfig) : void in class org.apache.pulsar.admin.cli.CmdSources.SourceDetailsCommand |
From |
To |
|
Change Variable Type serDe : SerDe<?> to serDe : SerDe in method public validateSerde(inputSerializer String, typeArg Class<?>, clsLoader ClassLoader, deser boolean) : void in class org.apache.pulsar.functions.utils.ValidatorUtils |
From |
To |
|
Change Variable Type isArchivePathUrl : boolean to sourcePkgUrl : String in method protected validateSinkConfigs(sinkConfig SinkConfig) : void in class org.apache.pulsar.admin.cli.CmdSinks.SinkDetailsCommand |
From |
To |
|
Rename Parameter name : String to className : String in method public implementsClass(className String, klass Class<?>, classLoader ClassLoader) : void in class org.apache.pulsar.functions.utils.Utils |
From |
To |
|
Rename Parameter serdeClassName : String to inputSerializer : String in method public validateSerde(inputSerializer String, typeArg Class<?>, clsLoader ClassLoader, deser boolean) : void in class org.apache.pulsar.functions.utils.ValidatorUtils |
From |
To |
|
Rename Parameter scheamType : String to schemaClassName : String in method private validateSchemaType(schemaClassName String, typeArg Class<?>, clsLoader ClassLoader, input boolean) : void in class org.apache.pulsar.functions.utils.ValidatorUtils |
From |
To |