Toggle navigation
Home
org.apache.flink.streaming.api.AggregationFunctionTest.MyPojo to org.apache.flink.streaming.api.AggregationFunctionTest.MyPojo3
No. of Instances - 5
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Different)
StreamReduce<MyPojo>
to
StreamGroupedReduce<>
ComparableAggregator<MyPojo>
to
ComparableAggregator<>
ReduceFunction<MyPojo>
to
ReduceFunction<MyPojo3>
ComparableAggregator<MyPojo>
to
ComparableAggregator<>
ReduceFunction<MyPojo>
to
ReduceFunction<MyPojo3>
ComparableAggregator<MyPojo>
to
ComparableAggregator<>
ReduceFunction<MyPojo>
to
ReduceFunction<MyPojo3>
ComparableAggregator<MyPojo>
to
ComparableAggregator<>
ReduceFunction<MyPojo>
to
ReduceFunction<MyPojo3>
StreamReduce<MyPojo>
to
StreamGroupedReduce<>
StreamReduce<MyPojo>
to
StreamGroupedReduce<>
StreamReduce<MyPojo>
to
StreamGroupedReduce<>
Add or Remove Method invocation
MockContext.createAndExecute(new StreamGroupedReduce<>(minByFunctionLast),getInputPojoList())
to
MockContext.createAndExecute(new StreamGroupedReduce<>(minByFunctionLast,keySelector),getInputByPojoList())
MockContext.createAndExecute(new StreamGroupedReduce<>(maxByFunctionFirst),getInputPojoList())
to
MockContext.createAndExecute(new StreamGroupedReduce<>(maxByFunctionFirst,keySelector),getInputByPojoList())
MockContext.createAndExecute(new StreamGroupedReduce<>(minByFunctionFirst),getInputPojoList())
to
MockContext.createAndExecute(new StreamGroupedReduce<>(minByFunctionFirst,keySelector),getInputByPojoList())
MockContext.createAndExecute(new StreamGroupedReduce<>(maxByFunctionLast),getInputPojoList())
to
MockContext.createAndExecute(new StreamGroupedReduce<>(maxByFunctionLast,keySelector),getInputByPojoList())
Update String Literal
"f0"
to
"f1"
"f0"
to
"f1"
"f0"
to
"f1"
"f0"
to
"f1"
Rename Variable
type1
to
typeInfo
type1
to
typeInfo
type1
to
typeInfo
type1
to
typeInfo