|
Change Return Type DataStream<Either<L,R>> to SingleOutputStreamOperator<Either<L,R>> in method public select(patternTimeoutFunction PatternTimeoutFunction<T,L>, patternSelectFunction PatternSelectFunction<T,R>) : SingleOutputStreamOperator<Either<L,R>> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Change Return Type DataStream<Map<String,T>> to SingleOutputStreamOperator<Map<String,T>> in method public createPatternStream(inputStream DataStream<T>, pattern Pattern<T,?>, lateDataOutputTag OutputTag<T>) : SingleOutputStreamOperator<Map<String,T>> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R> in method public select(patternSelectFunction PatternSelectFunction<T,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R> in method public flatSelect(patternFlatSelectFunction PatternFlatSelectFunction<T,R>) : SingleOutputStreamOperator<R> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R> in method public select(patternSelectFunction PatternSelectFunction<T,R>, outTypeInfo TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Change Return Type DataStream<R> to SingleOutputStreamOperator<R> in method public flatSelect(patternFlatSelectFunction PatternFlatSelectFunction<T,R>, outTypeInfo TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Change Return Type DataStream<Either<L,R>> to SingleOutputStreamOperator<Either<L,R>> in method public flatSelect(patternFlatTimeoutFunction PatternFlatTimeoutFunction<T,L>, patternFlatSelectFunction PatternFlatSelectFunction<T,R>) : SingleOutputStreamOperator<Either<L,R>> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Change Return Type DataStream<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> to SingleOutputStreamOperator<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> in method public createTimeoutPatternStream(inputStream DataStream<T>, pattern Pattern<T,?>, lateDataOutputTag OutputTag<T>) : SingleOutputStreamOperator<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Variable Type patternStream : DataStream<Map<String,T>> to patternStream : SingleOutputStreamOperator<Map<String,T>> in method public createPatternStream(inputStream DataStream<T>, pattern Pattern<T,?>, lateDataOutputTag OutputTag<T>) : SingleOutputStreamOperator<Map<String,T>> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Variable Type patternStream : DataStream<Map<String,T>> to patternStream : SingleOutputStreamOperator<Map<String,T>> in method public select(patternSelectFunction PatternSelectFunction<T,R>, outTypeInfo TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Change Variable Type patternStream : DataStream<Map<String,T>> to patternStream : SingleOutputStreamOperator<Map<String,T>> in method public flatSelect(patternFlatSelectFunction PatternFlatSelectFunction<T,R>, outTypeInfo TypeInformation<R>) : SingleOutputStreamOperator<R> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Change Variable Type patternStream : DataStream<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> to patternStream : SingleOutputStreamOperator<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> in method public flatSelect(patternFlatTimeoutFunction PatternFlatTimeoutFunction<T,L>, patternFlatSelectFunction PatternFlatSelectFunction<T,R>) : SingleOutputStreamOperator<Either<L,R>> in class org.apache.flink.cep.PatternStream |
From |
To |
|
Change Variable Type patternStream : DataStream<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> to patternStream : SingleOutputStreamOperator<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> in method public createTimeoutPatternStream(inputStream DataStream<T>, pattern Pattern<T,?>, lateDataOutputTag OutputTag<T>) : SingleOutputStreamOperator<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Variable Type patternStream : DataStream<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> to patternStream : SingleOutputStreamOperator<Either<Tuple2<Map<String,T>,Long>,Map<String,T>>> in method public select(patternTimeoutFunction PatternTimeoutFunction<T,L>, patternSelectFunction PatternSelectFunction<T,R>) : SingleOutputStreamOperator<Either<L,R>> in class org.apache.flink.cep.PatternStream |
From |
To |