Toggle navigation
Home
org.apache.flink.api.java.tuple.Tuple2 to org.apache.flink.api.java.tuple.Tuple3
No. of Instances - 59
No. of Commits - 12
No. of Projects - {'flink'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Cascading Type Change (Similar)
DataSet<Tuple2<K,VV>>
to
DataSet<Tuple3<K,K,EV>>
DataSet<Tuple2<K,VV>>
to
DataSet<Tuple3<K,K,EV>>
DataSet<Tuple2<K,VV>>
to
DataSet<Tuple3<K,K,EV>>
DataSet<Tuple2<K,VV>>
to
DataSet<Tuple3<K,K,EV>>
Tuple2<String,Integer>
to
Tuple3<Long,String,Integer>
Tuple2<String,Integer>
to
Tuple3<>
OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>>
to
OneInputStreamOperator<Tuple2<String,Integer>,Tuple3<String,String,Integer>>
DataStream<Tuple3<String,String,Integer>>
to
DataStream<String>
DataStream<Tuple2<String,Integer>>
to
DataStream<String>
DataStream<Tuple3<String,String,Integer>>
to
DataStream<String>
DataStream<Tuple2<String,Integer>>
to
DataStream<Integer>
DataStream<Tuple2<String,Integer>>
to
DataStream<Integer>
DataStream<Tuple2<String,Integer>>
to
DataStream<Integer>
DataStream<Tuple3<String,String,Integer>>
to
DataStream<String>
DataStream<Tuple3<String,String,Integer>>
to
DataStream<String>
Rename Variable
v
to
edges
vertices
to
e
v
to
edges
v
to
edges
vertices
to
e
v
to
edges
type1
to
typeInfo
type1
to
typeInfo
type1
to
typeInfo
type1
to
typeInfo
operator1
to
operator
operator1
to
operator
operator1
to
operator
transform1
to
transform
Cascading Type Change (Different)
DataSet<Tuple2<K,VV>>
to
DataSet<Tuple3<K,K,EV>>
DataSet<Tuple2<K,VV>>
to
DataSet<Tuple3<K,K,EV>>
StreamReduce<Tuple2<Integer,Integer>>
to
StreamGroupedReduce<>
StreamReduce<Tuple2<Integer,Integer>>
to
StreamGroupedReduce<>
ComparableAggregator<Tuple2<Integer,Integer>>
to
ComparableAggregator<>
ReduceFunction<Tuple2<Integer,Integer>>
to
ReduceFunction<Tuple3<Integer,Integer,Integer>>
ComparableAggregator<Tuple2<Integer,Integer>>
to
ComparableAggregator<>
ReduceFunction<Tuple2<Integer,Integer>>
to
ReduceFunction<Tuple3<Integer,Integer,Integer>>
ComparableAggregator<Tuple2<Integer,Integer>>
to
ComparableAggregator<>
ReduceFunction<Tuple2<Integer,Integer>>
to
ReduceFunction<Tuple3<Integer,Integer,Integer>>
ComparableAggregator<Tuple2<Integer,Integer>>
to
ComparableAggregator<>
ReduceFunction<Tuple2<Integer,Integer>>
to
ReduceFunction<Tuple3<Integer,Integer,Integer>>
StreamReduce<Tuple2<Integer,Integer>>
to
StreamGroupedReduce<>
StreamReduce<Tuple2<Integer,Integer>>
to
StreamGroupedReduce<>
EvictingWindowOperator
to
EvictingWindowOperator<String,Tuple2<String,Integer>,?,?>
OneInputStreamOperator<Tuple2<String,Integer>,Tuple2<String,Integer>>
to
OneInputStreamOperator<Tuple2<String,Integer>,Tuple3<String,String,Integer>>
TupleKeySelector
to
Tuple3KeySelector
ProcessWindowFunction<Tuple2<String,Integer>,Tuple2<String,Integer>,String,TimeWindow>
to
TestProcessWindowFunction
TupleKeySelector
to
Tuple3KeySelector
TupleKeySelector
to
Tuple3KeySelector
TupleKeySelector
to
Tuple3KeySelector
TupleKeySelector
to
Tuple3KeySelector
TupleKeySelector
to
Tuple3KeySelector
TupleKeySelector
to
Tuple3KeySelector
TupleKeySelector
to
Tuple3KeySelector
CassandraTupleOutputFormat<Tuple2<Integer,String>>
to
CassandraTupleOutputFormat<>
Add or Remove Method invocation
MockContext.createAndExecute(new StreamGroupedReduce<>(minByFunctionLast),getInputList())
to
MockContext.createAndExecute(new StreamGroupedReduce<>(minByFunctionLast,keySelector),getInputByList())
MockContext.createAndExecute(new StreamGroupedReduce<>(maxByFunctionLast),getInputList())
to
MockContext.createAndExecute(new StreamGroupedReduce<>(maxByFunctionLast,keySelector),getInputByList())
MockContext.createAndExecute(new StreamGroupedReduce<>(minByFunctionFirst),getInputList())
to
MockContext.createAndExecute(new StreamGroupedReduce<>(minByFunctionFirst,keySelector),getInputByList())
MockContext.createAndExecute(new StreamGroupedReduce<>(maxByFunctionFirst),getInputList())
to
MockContext.createAndExecute(new StreamGroupedReduce<>(maxByFunctionFirst,keySelector),getInputByList())
aggregate
to
aggregate
Update Number Literal
0
to
1
0
to
1
0
to
1
0
to
1
Other
new ClusterBuilder(){ @Override protected Cluster buildCluster( Cluster.Builder builder){ return builder.addContactPoints("127.0.0.1").build(); } }
to
clusterBuilder