|
Rename Method public partitionBy(fields String...) : DataStream<OUT> renamed to public partitionByHash(fields String...) : DataStream<OUT> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Method public partitionBy(fields int...) : DataStream<OUT> renamed to public partitionByHash(fields int...) : DataStream<OUT> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Method public distribute() : SingleOutputStreamOperator<OUT,O> renamed to public rebalance() : SingleOutputStreamOperator<OUT,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Rename Method public partitionBy(keySelector1 KeySelector<IN1,?>, keySelector2 KeySelector<IN2,?>) : ConnectedDataStream<IN1,IN2> renamed to public partitionByHash(keySelector1 KeySelector<IN1,?>, keySelector2 KeySelector<IN2,?>) : ConnectedDataStream<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Rename Method public partitionBy(keySelector KeySelector<OUT,?>) : DataStream<OUT> renamed to public partitionByHash(keySelector KeySelector<OUT,?>) : DataStream<OUT> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Method private partitionBy(keys Keys<OUT>) : DataStream<OUT> renamed to private partitionByHash(keys Keys<OUT>) : DataStream<OUT> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Method protected getEdge(sourceId int, targetId int) : StreamEdge renamed to public getStreamEdge(sourceId int, targetId int) : StreamEdge in class org.apache.flink.streaming.api.graph.StreamGraph |
From |
To |
|
Rename Method public partitionBy(keyPosition1 int, keyPosition2 int) : ConnectedDataStream<IN1,IN2> renamed to public partitionByHash(keyPosition1 int, keyPosition2 int) : ConnectedDataStream<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Rename Method public partitionBy(keyPositions1 int[], keyPositions2 int[]) : ConnectedDataStream<IN1,IN2> renamed to public partitionByHash(keyPositions1 int[], keyPositions2 int[]) : ConnectedDataStream<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Rename Method public partitionBy(fields1 String[], fields2 String[]) : ConnectedDataStream<IN1,IN2> renamed to public partitionByHash(fields1 String[], fields2 String[]) : ConnectedDataStream<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Rename Method public distribute() : DataStream<OUT> renamed to public rebalance() : DataStream<OUT> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Method private validateMerge(id Integer) : void renamed to private validateUnion(id Integer) : void in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Method public merge(streams DataStream<OUT>...) : DataStream<OUT> renamed to public union(streams DataStream<OUT>...) : DataStream<OUT> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Rename Method public partitionBy(field1 String, field2 String) : ConnectedDataStream<IN1,IN2> renamed to public partitionByHash(field1 String, field2 String) : ConnectedDataStream<IN1,IN2> in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |