e9a1b9a58b28687558b29705ea66047ef82fd05c
Files Diff
- Added: 4
- Removed: 3
- Renamed: 0
- Modified: 25
Refactorings reported:
Refactoring Name | Occurences | ||
---|---|---|---|
Change Parameter Type | 2 | ||
Change Parameter Type inputSerDe : Map<String,SerDe> to inputType : Class<?> in method public setupInput(inputType Class<?>) : void in class org.apache.pulsar.functions.instance.processors.MessageProcessorBase | From | To | |
Change Parameter Type inputSerDe : Map<String,SerDe> to inputType : Class<?> in method public setupInput(inputType Class<?>) : void in class org.apache.pulsar.functions.instance.processors.MessageProcessor | From | To | |
Move Method | 4 | ||
Move Method private convert(functionConfig FunctionConfig) : FunctionDetails from class org.apache.pulsar.admin.cli.CmdFunctions to protected convert(functionConfig FunctionConfig) : FunctionDetails from class org.apache.pulsar.admin.cli.CmdFunctions.FunctionDetailsCommand | From | To | |
Move Method public testVoidInputClasses() : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnableTest to public testVoidInputClasses() : void from class org.apache.pulsar.functions.source.PulsarSourceTest | From | To | |
Move Method private convertProto2(functionConfig FunctionConfig) : Function.FunctionDetails from class org.apache.pulsar.admin.cli.CmdFunctions to protected convertProto2(functionConfig FunctionConfig) : Function.FunctionDetails from class org.apache.pulsar.admin.cli.CmdFunctions.FunctionDetailsCommand | From | To | |
Move Method public testInconsistentInputType() : void from class org.apache.pulsar.functions.instance.JavaInstanceRunnableTest to public testInconsistentInputType() : void from class org.apache.pulsar.functions.source.PulsarSourceTest | From | To | |
Rename Variable | 1 | ||
Rename Variable connectorDetails : Function.ConnectorDetails to sourceSpec : Function.SourceSpec in method public setupInput(inputType Class<?>) : void in class org.apache.pulsar.functions.instance.processors.MessageProcessorBase | From | To | |
Change Return Type | 2 | ||
Change Return Type FunctionDetails.ProcessingGuarantees to ProcessingGuarantees in method private convertProcessingGuarantee(processingGuarantees FunctionConfig.ProcessingGuarantees) : ProcessingGuarantees in class org.apache.pulsar.admin.cli.CmdFunctions | From | To | |
Change Return Type FunctionDetails.SubscriptionType to SubscriptionType in method private convertSubscriptionType(subscriptionType FunctionConfig.SubscriptionType) : SubscriptionType in class org.apache.pulsar.admin.cli.CmdFunctions | From | To | |
Extract Class | 1 | ||
Extract Class org.apache.pulsar.functions.source.PulsarSourceTest from class org.apache.pulsar.functions.instance.JavaInstanceRunnableTest | From | To | |
Move Class | 2 | ||
Move Class org.apache.pulsar.functions.instance.PulsarSource moved to org.apache.pulsar.functions.source.PulsarSource | From | To | |
Move Class org.apache.pulsar.functions.instance.PulsarRecord moved to org.apache.pulsar.functions.source.PulsarRecord | From | To | |
Change Variable Type | 4 | ||
Change Variable Type type : FunctionDetails.ProcessingGuarantees to type : ProcessingGuarantees in method private convertProcessingGuarantee(processingGuarantees FunctionConfig.ProcessingGuarantees) : ProcessingGuarantees in class org.apache.pulsar.admin.cli.CmdFunctions | From | To | |
Change Variable Type type : FunctionDetails.SubscriptionType to type : SubscriptionType in method private convertSubscriptionType(subscriptionType FunctionConfig.SubscriptionType) : SubscriptionType in class org.apache.pulsar.admin.cli.CmdFunctions | From | To | |
Change Variable Type connectorDetails : Function.ConnectorDetails to sourceSpec : Function.SourceSpec in method public setupInput(inputType Class<?>) : void in class org.apache.pulsar.functions.instance.processors.MessageProcessorBase | From | To | |
Change Variable Type sourceConfigs : Map<String,String> to sourceConfigs : 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 | |
Change Attribute Type | 1 | ||
Change Attribute Type processingGuarantees : FunctionDetails.ProcessingGuarantees to processingGuarantees : ProcessingGuarantees in class org.apache.pulsar.functions.runtime.JavaInstanceMain | From | To | |
Rename Parameter | 2 | ||
Rename Parameter inputSerDe : Map<String,SerDe> to inputType : Class<?> in method public setupInput(inputType Class<?>) : void in class org.apache.pulsar.functions.instance.processors.MessageProcessorBase | From | To | |
Rename Parameter inputSerDe : Map<String,SerDe> to inputType : Class<?> in method public setupInput(inputType Class<?>) : void in class org.apache.pulsar.functions.instance.processors.MessageProcessor | From | To |