|
Change Parameter Type typeClass : Class<OUT> to typeClass : Class<T> in method public returns(typeClass Class<T>) : O in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Parameter Type input2 : DataStream<IN2> to input1 : DataStream<IN1> in method protected ConnectedDataStream(env StreamExecutionEnvironment, input1 DataStream<IN1>, input2 DataStream<IN2>) in class org.apache.flink.streaming.api.datastream.ConnectedDataStream |
From |
To |
|
Change Parameter Type typeInfo : TypeInformation<OUT> to typeInfo : TypeInformation<T> in method public returns(typeInfo TypeInformation<T>) : O in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Parameter Type keys : Keys<OUT> to keys : Keys<T> in method private groupBy(keys Keys<T>) : GroupedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type outTypeInfo : TypeInformation<OUT> to outTypeInfo : TypeInformation<T> in method public DataStreamSource(environment StreamExecutionEnvironment, outTypeInfo TypeInformation<T>, operator StreamSource<T>, isParallel boolean, sourceName String) in class org.apache.flink.streaming.api.datastream.DataStreamSource |
From |
To |
|
Change Parameter Type ds : DataStream<Tuple2<I1,I2>> to ds : DataStream<R> in method private JoinedStream(predicate JoinPredicate<I1,I2>, ds DataStream<R>) in class org.apache.flink.streaming.api.datastream.temporal.StreamJoinOperator.JoinPredicate.JoinedStream |
From |
To |
|
Change Parameter Type key : KeySelector<OUT,?> to key : KeySelector<T,?> in method public keyBy(key KeySelector<T,?>) : KeyedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type filter : FilterFunction<OUT> to filter : FilterFunction<T> in method public filter(filter FilterFunction<T>) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type operator : OneInputStreamOperator<OUT,R> to operator : OneInputStreamOperator<T,R> in method public transform(operatorName String, outTypeInfo TypeInformation<R>, operator OneInputStreamOperator<T,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.KeyedDataStream |
From |
To |
|
Change Parameter Type operator : StreamOperator<OUT> to operator : StreamSource<T> in method public DataStreamSource(environment StreamExecutionEnvironment, outTypeInfo TypeInformation<T>, operator StreamSource<T>, isParallel boolean, sourceName String) in class org.apache.flink.streaming.api.datastream.DataStreamSource |
From |
To |
|
Change Parameter Type keys : Keys<OUT> to keys : Keys<T> in method private keyBy(keys Keys<T>) : KeyedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type schema : SerializationSchema<OUT,byte[]> to schema : SerializationSchema<T,byte[]> in method public writeToSocket(hostName String, port int, schema SerializationSchema<T,byte[]>) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type flatMapper : FlatMapFunction<OUT,R> to flatMapper : FlatMapFunction<T,R> in method public flatMap(flatMapper FlatMapFunction<T,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type keySelector : KeySelector<OUT,?> to keySelector : KeySelector<T,?> in method public partitionByHash(keySelector KeySelector<T,?>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type keys : Keys<OUT> to keys : Keys<T> in method private partitionCustom(partitioner Partitioner<K>, keys Keys<T>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type format : OutputFormat<OUT> to format : OutputFormat<T> in method public write(format OutputFormat<T>, millis long) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type eviction : EvictionPolicy<OUT> to eviction : EvictionPolicy<T> in method public window(trigger TriggerPolicy<T>, eviction EvictionPolicy<T>) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type keySelector : KeySelector<OUT,?> to keySelector : KeySelector<T,?> in method public groupBy(keySelector KeySelector<T,?>) : GroupedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type keys : Keys<OUT> to keys : Keys<T> in method private partitionByHash(keys Keys<T>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type mapper : MapFunction<OUT,R> to mapper : MapFunction<T,R> in method public map(mapper MapFunction<T,R>) : SingleOutputStreamOperator<R,?> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type trigger : TriggerPolicy<OUT> to trigger : TriggerPolicy<T> in method public window(trigger TriggerPolicy<T>, eviction EvictionPolicy<T>) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type partitioner : StreamPartitioner<OUT> to partitioner : StreamPartitioner<T> in method protected setConnectionType(partitioner StreamPartitioner<T>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.KeyedDataStream |
From |
To |
|
Change Parameter Type keySelector : KeySelector<OUT,K> to keySelector : KeySelector<T,K> in method public partitionCustom(partitioner Partitioner<K>, keySelector KeySelector<T,K>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Parameter Type dataStream : DataStream<IN> to dataStream : DataStream<T> in method protected IterativeDataStream(dataStream DataStream<T>, maxWaitTime long) in class org.apache.flink.streaming.api.datastream.IterativeDataStream |
From |
To |
|
Change Variable Type tof : TextOutputFormat<OUT> to tof : TextOutputFormat<T> in method public writeAsText(path String, writeMode WriteMode) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Variable Type head3 : DataStream<Integer> to head3 : DataStreamSink<Integer> in method public testmultipleHeadsTailsWithTailPartitioning() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type dataStream2 : DataStream<String> to dataStream2 : DataStreamSink<String> in method public main(args String[]) : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQTopology |
From |
To |
|
Change Variable Type returnStream : DataStreamSink<OUT> to returnStream : DataStreamSink<T> in method public writeToSocket(hostName String, port int, schema SerializationSchema<T,byte[]>) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Variable Type outExpressionKeys : Keys.ExpressionKeys<OUT> to outExpressionKeys : Keys.ExpressionKeys<T> in method public partitionCustom(partitioner Partitioner<K>, field int) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Variable Type tof : TextOutputFormat<OUT> to tof : TextOutputFormat<T> in method public writeAsText(path String, millis long) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Variable Type sink2 : DataStream<Long> to sink2 : DataStreamSink<Long> in method public sinkKeyTest() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type dataStream1 : DataStream<String> to dataStream1 : DataStreamSink<String> in method public main(args String[]) : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQTopology |
From |
To |
|
Change Variable Type dataStream : DataStream<Tuple2<Integer,Integer>> to dataStream : DataStreamSink<Tuple2<Integer,Integer>> in method public sameDataStreamTest() : void in class org.apache.flink.streaming.api.operators.co.SelfConnectionTest |
From |
To |
|
Change Variable Type tof : TextOutputFormat<OUT> to tof : TextOutputFormat<T> in method public writeAsText(path String, writeMode WriteMode, millis long) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Variable Type outExpressionKeys : Keys.ExpressionKeys<OUT> to outExpressionKeys : Keys.ExpressionKeys<T> in method public partitionCustom(partitioner Partitioner<K>, field String) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Variable Type keySelector : KeySelector<OUT,K> to keySelector : KeySelector<T,K> in method private partitionCustom(partitioner Partitioner<K>, keys Keys<T>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Variable Type head3 : DataStream<Integer> to head3 : DataStreamSink<Integer> in method public testmultipleHeadsTailsSimple() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type head4 : DataStream<Integer> to head4 : DataStreamSink<Integer> in method public testmultipleHeadsTailsWithTailPartitioning() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type ti : TypeInformation<OUT> to ti : TypeInformation<T> in method public returns(typeClass Class<T>) : O in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Variable Type sink3 : DataStream<Long> to sink3 : DataStreamSink<Long> in method public sinkKeyTest() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type connected : DataStream<Long> to connected : DataStreamSink<Long> in method public testNaming() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type sink : DataStream<Long> to sink : DataStreamSink<Long> in method public sinkKeyTest() : void in class org.apache.flink.streaming.api.DataStreamTest |
From |
To |
|
Change Variable Type head4 : DataStream<Integer> to head4 : DataStreamSink<Integer> in method public testmultipleHeadsTailsSimple() : void in class org.apache.flink.streaming.api.IterateTest |
From |
To |
|
Change Variable Type printFunction : PrintSinkFunction<OUT> to printFunction : PrintSinkFunction<T> in method public printToErr() : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Variable Type printFunction : PrintSinkFunction<OUT> to printFunction : PrintSinkFunction<T> in method public print() : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Variable Type sourceOperator : StreamOperator<OUT> to sourceOperator : StreamSource<OUT> in method public addSource(function SourceFunction<OUT>, sourceName String, typeInfo TypeInformation<OUT>) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Change Return Type DataStreamSink<OUT> to DataStreamSink<T> in method public writeAsText(path String, writeMode WriteMode) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type TypeInformation<OUT> to TypeInformation<T> in method public getType() : TypeInformation<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,O> to SingleOutputStreamOperator<T,O> in method public broadcast() : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method public partitionByHash(fields int...) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type ConnectedIterativeDataStream<IN,F> to ConnectedIterativeDataStream<T,F> in method public withFeedbackType(feedbackTypeString String) : ConnectedIterativeDataStream<T,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream |
From |
To |
|
Change Return Type CrossWindow<I1,I2> to CrossWindow<I1,I2,R> in method public every(length long) : CrossWindow<I1,I2,R> in class org.apache.flink.streaming.api.datastream.temporal.StreamCrossOperator.CrossWindow |
From |
To |
|
Change Return Type StreamJoinOperator<OUT,IN2> to StreamJoinOperator<T,IN2> in method public join(dataStreamToJoin DataStream<IN2>) : StreamJoinOperator<T,IN2> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,O> to SingleOutputStreamOperator<T,O> in method public setBufferTimeout(timeoutMillis long) : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,O> to SingleOutputStreamOperator<T,O> in method public setParallelism(parallelism int) : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,O> to SingleOutputStreamOperator<T,O> in method public forward() : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method public partitionCustom(partitioner Partitioner<K>, field String) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method public global() : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type JoinedStream<I1,I2> to JoinedStream<I1,I2,Tuple2<I1,I2>> in method public equalTo(keySelector KeySelector<I2,K>) : JoinedStream<I1,I2,Tuple2<I1,I2>> in class org.apache.flink.streaming.api.datastream.temporal.StreamJoinOperator.JoinPredicate |
From |
To |
|
Change Return Type DataStreamSink<OUT> to DataStreamSink<T> in method public printToErr() : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,O> to SingleOutputStreamOperator<T,O> in method public isolateResources() : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type ConnectedDataStream<OUT,R> to ConnectedDataStream<T,R> in method public connect(dataStream DataStream<R>) : ConnectedDataStream<T,R> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type CrossWindow<I1,I2> to CrossWindow<I1,I2,R> in method public every(length long, timeUnit TimeUnit) : CrossWindow<I1,I2,R> in class org.apache.flink.streaming.api.datastream.temporal.StreamCrossOperator.CrossWindow |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,O> to SingleOutputStreamOperator<T,O> in method private setChainingStrategy(strategy ChainingStrategy) : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type IterativeDataStream<OUT> to IterativeDataStream<T> in method public iterate() : IterativeDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,O> to SingleOutputStreamOperator<T,O> in method public startNewResourceGroup() : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type JoinedStream<I1,I2> to JoinedStream<I1,I2,Tuple2<I1,I2>> in method public equalTo(fields String...) : JoinedStream<I1,I2,Tuple2<I1,I2>> in class org.apache.flink.streaming.api.datastream.temporal.StreamJoinOperator.JoinPredicate |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method public partitionByHash(keySelector KeySelector<T,?>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStreamSink<OUT> to DataStreamSink<T> in method public writeAsText(path String) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStreamSink<OUT> to DataStreamSink<T> in method public writeAsText(path String, millis long) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type KeyedDataStream<OUT> to KeyedDataStream<T> in method public keyBy(fields String...) : KeyedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public window(trigger TriggerPolicy<T>, eviction EvictionPolicy<T>) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method private partitionCustom(partitioner Partitioner<K>, keys Keys<T>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,O> to SingleOutputStreamOperator<T,O> in method public global() : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type DataStreamSource<OUT> to DataStreamSource<T> in method public setParallelism(parallelism int) : DataStreamSource<T> in class org.apache.flink.streaming.api.datastream.DataStreamSource |
From |
To |
|
Change Return Type KeyedDataStream<OUT> to KeyedDataStream<T> in method private keyBy(keys Keys<T>) : KeyedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method public partitionByHash(fields String...) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,O> to SingleOutputStreamOperator<T,O> in method public shuffle() : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public every(policyHelper WindowingHelper) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method public rebalance() : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type WindowedDataStream<OUT> to WindowedDataStream<T> in method public window(policyHelper WindowingHelper) : WindowedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method private partitionByHash(keys Keys<T>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type GroupedDataStream<OUT> to GroupedDataStream<T> in method public groupBy(keySelector KeySelector<T,?>) : GroupedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type JoinedStream<I1,I2> to JoinedStream<I1,I2,Tuple2<I1,I2>> in method private createJoinOperator() : JoinedStream<I1,I2,Tuple2<I1,I2>> in class org.apache.flink.streaming.api.datastream.temporal.StreamJoinOperator.JoinPredicate |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,?> to SingleOutputStreamOperator<T,?> in method public filter(filter FilterFunction<T>) : SingleOutputStreamOperator<T,?> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStreamSink<OUT> to DataStreamSink<T> in method public writeAsCsv(path String, writeMode WriteMode, millis long) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type GroupedDataStream<OUT> to GroupedDataStream<T> in method public groupBy(fields int...) : GroupedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStreamSink<OUT> to DataStreamSink<T> in method public print() : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,O> to SingleOutputStreamOperator<T,O> in method public rebalance() : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method public shuffle() : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method public partitionCustom(partitioner Partitioner<K>, keySelector KeySelector<T,K>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type IterativeDataStream<OUT> to IterativeDataStream<T> in method public iterate(maxWaitTimeMillis long) : IterativeDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStreamSink<OUT> to DataStreamSink<T> in method public write(format OutputFormat<T>, millis long) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStreamSink<OUT> to DataStreamSink<T> in method public writeAsText(path String, writeMode WriteMode, millis long) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,O> to SingleOutputStreamOperator<T,O> in method public startNewChain() : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type JoinedStream<I1,I2> to JoinedStream<I1,I2,Tuple2<I1,I2>> in method public equalTo(fields int...) : JoinedStream<I1,I2,Tuple2<I1,I2>> in class org.apache.flink.streaming.api.datastream.temporal.StreamJoinOperator.JoinPredicate |
From |
To |
|
Change Return Type ConnectedIterativeDataStream<IN,F> to ConnectedIterativeDataStream<T,F> in method public withFeedbackType(feedbackType TypeInformation<F>) : ConnectedIterativeDataStream<T,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream |
From |
To |
|
Change Return Type DataStream<OUT> to SingleOutputStreamOperator<T,O> in method public name(name String) : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type SingleOutputStreamOperator<OUT,O> to SingleOutputStreamOperator<T,O> in method public disableChaining() : SingleOutputStreamOperator<T,O> in class org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator |
From |
To |
|
Change Return Type DataStreamSink<OUT> to DataStreamSink<T> in method public writeAsCsv(path String) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method protected setConnectionType(partitioner StreamPartitioner<T>) : DataStream<T> in class org.apache.flink.streaming.api.datastream.KeyedDataStream |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method public forward() : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type KeyedDataStream<OUT> to KeyedDataStream<T> in method public keyBy(fields int...) : KeyedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStreamSink<OUT> to DataStreamSink<T> in method public writeAsCsv(path String, writeMode WriteMode) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method public broadcast() : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type ConnectedIterativeDataStream<IN,F> to ConnectedIterativeDataStream<T,F> in method public withFeedbackType(feedbackTypeClass Class<F>) : ConnectedIterativeDataStream<T,F> in class org.apache.flink.streaming.api.datastream.IterativeDataStream |
From |
To |
|
Change Return Type GroupedDataStream<OUT> to GroupedDataStream<T> in method private groupBy(keys Keys<T>) : GroupedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type CrossWindow<I1,I2> to CrossWindow<I1,I2,Tuple2<I1,I2>> in method protected createNextWindowOperator() : CrossWindow<I1,I2,Tuple2<I1,I2>> in class org.apache.flink.streaming.api.datastream.temporal.StreamCrossOperator |
From |
To |
|
Change Return Type GroupedDataStream<OUT> to GroupedDataStream<T> in method public groupBy(fields String...) : GroupedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStream<OUT> to DataStream<T> in method public partitionCustom(partitioner Partitioner<K>, field int) : DataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type DataStreamSink<OUT> to DataStreamSink<T> in method public writeAsCsv(path String, millis long) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type StreamCrossOperator<OUT,IN2> to StreamCrossOperator<T,IN2> in method public cross(dataStreamToCross DataStream<IN2>) : StreamCrossOperator<T,IN2> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type KeySelector<OUT,?> to KeySelector<T,?> in method public getKeySelector() : KeySelector<T,?> in class org.apache.flink.streaming.api.datastream.KeyedDataStream |
From |
To |
|
Change Return Type DataStreamSink<OUT> to DataStreamSink<T> in method public writeToSocket(hostName String, port int, schema SerializationSchema<T,byte[]>) : DataStreamSink<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |
|
Change Return Type KeyedDataStream<OUT> to KeyedDataStream<T> in method public keyBy(key KeySelector<T,?>) : KeyedDataStream<T> in class org.apache.flink.streaming.api.datastream.DataStream |
From |
To |