d8dbaeeb4df4524e136423425edc9d87d1f25897
Files Diff
- Added: 3
- Removed: 1
- Renamed: 0
- Modified: 32
Refactorings reported:
| Refactoring Name | Occurences | ||
|---|---|---|---|
| Rename Method | 4 | ||
| Rename Method public testCustomType() : void renamed to public testGenericType() : void in class org.apache.flink.api.java.typeutils.TypeInfoParserTest | From | To | |
| Rename Method public testTypeErasureException() : void renamed to public testTypeErasure() : void in class org.apache.flink.api.java.type.extractor.TypeExtractorTest | From | To | |
| Rename Method public testFunctionDependingOnInputException() : void renamed to public testFunctionDependingOnUnknownInput() : void in class org.apache.flink.api.java.type.extractor.TypeExtractorTest | From | To | |
| Rename Method public testMissingTupleGenericsException() : void renamed to public testMissingTupleGenerics() : void in class org.apache.flink.api.java.type.extractor.TypeExtractorTest | From | To | |
| Rename Variable | 1 | ||
| Rename Variable customObjectMatcher : Matcher to pojoGenericMatcher : Matcher in method private parse(sb StringBuilder) : TypeInformation<?> in class org.apache.flink.api.java.typeutils.TypeInfoParser | From | To | |
| Inline Method | 1 | ||
| Inline Method private init() : void inlined to public clearProperties() : void in class org.apache.flink.api.common.operators.SemanticProperties | From | To | |
| Change Return Type | 1 | ||
| Change Return Type void to DualInputSemanticProperties in method protected extractSemanticAnnotationsFromUdf(udfClass Class<?>) : DualInputSemanticProperties in class org.apache.flink.api.java.operators.TwoInputUdfOperator | From | To | |
| Rename Class | 1 | ||
| Rename Class org.apache.flink.api.java.operators.translation.DistrinctTranslationTest renamed to org.apache.flink.api.java.operators.translation.DistinctTranslationTest | From | To | |
| Rename Attribute | 1 | ||
| Rename Attribute customObjectPattern : Pattern to pojoGenericObjectPattern : Pattern in class org.apache.flink.api.java.typeutils.TypeInfoParser | From | To | |
| Extract Variable | 4 | ||
| Extract Variable callLocation : String in method public flatMap(flatMapper FlatMapFunction<T,R>) : FlatMapOperator<T,R> from class org.apache.flink.api.java.DataSet | From | To | |
| Extract Variable callLocation : String in method public mapPartition(mapPartition MapPartitionFunction<T,R>) : MapPartitionOperator<T,R> from class org.apache.flink.api.java.DataSet | From | To | |
| Extract Variable callLocation : String in method public reduceGroup(reducer GroupReduceFunction<T,R>) : GroupReduceOperator<T,R> from class org.apache.flink.api.java.DataSet | From | To | |
| Extract Variable callLocation : String in method public map(mapper MapFunction<T,R>) : MapOperator<T,R> from class org.apache.flink.api.java.DataSet | From | To | |
| Extract Method | 13 | ||
| Extract Method private loadClass(fullyQualifiedName String) : Class<?> extracted from private parse(sb StringBuilder) : TypeInformation<?> in class org.apache.flink.api.java.typeutils.TypeInfoParser | From | To | |
| Extract Method public getFlatMapReturnTypes(flatMapInterface FlatMapFunction<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> extracted from public getFlatMapReturnTypes(flatMapInterface FlatMapFunction<IN,OUT>, inType TypeInformation<IN>) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor | From | To | |
| Extract Method public getMapPartitionReturnTypes(mapPartitionInterface MapPartitionFunction<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> extracted from public getMapPartitionReturnTypes(mapPartitionInterface MapPartitionFunction<IN,OUT>, inType TypeInformation<IN>) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor | From | To | |
| Extract Method public getCrossReturnTypes(crossInterface CrossFunction<IN1,IN2,OUT>, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>, functionName String, allowMissing boolean) : TypeInformation<OUT> extracted from public getCrossReturnTypes(crossInterface CrossFunction<IN1,IN2,OUT>, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor | From | To | |
| Extract Method public getFlatJoinReturnTypes(joinInterface FlatJoinFunction<IN1,IN2,OUT>, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>, functionName String, allowMissing boolean) : TypeInformation<OUT> extracted from public getFlatJoinReturnTypes(joinInterface FlatJoinFunction<IN1,IN2,OUT>, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor | From | To | |
| Extract Method public getMapReturnTypes(mapInterface MapFunction<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> extracted from public getMapReturnTypes(mapInterface MapFunction<IN,OUT>, inType TypeInformation<IN>) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor | From | To | |
| Extract Method public getJoinReturnTypes(joinInterface JoinFunction<IN1,IN2,OUT>, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>, functionName String, allowMissing boolean) : TypeInformation<OUT> extracted from public getJoinReturnTypes(joinInterface JoinFunction<IN1,IN2,OUT>, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor | From | To | |
| Extract Method public getPartitionerTypes(partitioner Partitioner<T>, functionName String, allowMissing boolean) : TypeInformation<T> extracted from public getPartitionerTypes(partitioner Partitioner<T>) : TypeInformation<T> in class org.apache.flink.api.java.typeutils.TypeExtractor | From | To | |
| Extract Method public getGroupReduceReturnTypes(groupReduceInterface GroupReduceFunction<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> extracted from public getGroupReduceReturnTypes(groupReduceInterface GroupReduceFunction<IN,OUT>, inType TypeInformation<IN>) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor | From | To | |
| Extract Method public getCoGroupReturnTypes(coGroupInterface CoGroupFunction<IN1,IN2,OUT>, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>, functionName String, allowMissing boolean) : TypeInformation<OUT> extracted from public getCoGroupReturnTypes(coGroupInterface CoGroupFunction<IN1,IN2,OUT>, in1Type TypeInformation<IN1>, in2Type TypeInformation<IN2>) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor | From | To | |
| Extract Method public getKeySelectorTypes(selectorInterface KeySelector<IN,OUT>, inType TypeInformation<IN>, functionName String, allowMissing boolean) : TypeInformation<OUT> extracted from public getKeySelectorTypes(selectorInterface KeySelector<IN,OUT>, inType TypeInformation<IN>) : TypeInformation<OUT> in class org.apache.flink.api.java.typeutils.TypeExtractor | From | To | |
| Rename Parameter | 1 | ||
| Rename Parameter type : TypeInformation<T> to typeInfo : TypeInformation<T> in method protected DataSet(context ExecutionEnvironment, typeInfo TypeInformation<T>) in class org.apache.flink.api.java.DataSet | From | To |