|
Change Parameter Type selectFunction : PatternSelectFunction<IN,OUT1> to selectFunction : PatternFlatSelectFunction<IN,OUT1> in method public createTimeoutPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, comparator EventComparator<IN>, selectFunction PatternFlatSelectFunction<IN,OUT1>, outTypeInfo TypeInformation<OUT1>, outputTag OutputTag<OUT2>, timeoutFunction PatternFlatTimeoutFunction<IN,OUT2>, lateDataOutputTag OutputTag<IN>) : SingleOutputStreamOperator<OUT1> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Parameter Type timeoutFunction : PatternTimeoutFunction<IN,OUT2> to timeoutFunction : PatternFlatTimeoutFunction<IN,OUT2> in method public createTimeoutPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, comparator EventComparator<IN>, selectFunction PatternFlatSelectFunction<IN,OUT1>, outTypeInfo TypeInformation<OUT1>, outputTag OutputTag<OUT2>, timeoutFunction PatternFlatTimeoutFunction<IN,OUT2>, lateDataOutputTag OutputTag<IN>) : SingleOutputStreamOperator<OUT1> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Parameter Type selectFunction : PatternSelectFunction<IN,OUT> to selectFunction : PatternFlatSelectFunction<IN,OUT> in method public createPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, comparator EventComparator<IN>, selectFunction PatternFlatSelectFunction<IN,OUT>, outTypeInfo TypeInformation<OUT>, lateDataOutputTag OutputTag<IN>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Parameter Type timeoutFunction : PatternFlatTimeoutFunction<IN,OUT2> to timeoutFunction : PatternTimeoutFunction<IN,OUT2> in method public createTimeoutPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, comparator EventComparator<IN>, selectFunction PatternSelectFunction<IN,OUT1>, outTypeInfo TypeInformation<OUT1>, outputTag OutputTag<OUT2>, timeoutFunction PatternTimeoutFunction<IN,OUT2>, lateDataOutputTag OutputTag<IN>) : SingleOutputStreamOperator<OUT1> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Parameter Type selectFunction : PatternFlatSelectFunction<IN,OUT> to selectFunction : PatternSelectFunction<IN,OUT> in method public createPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, comparator EventComparator<IN>, selectFunction PatternSelectFunction<IN,OUT>, outTypeInfo TypeInformation<OUT>, lateDataOutputTag OutputTag<IN>) : SingleOutputStreamOperator<OUT> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |
|
Change Parameter Type selectFunction : PatternFlatSelectFunction<IN,OUT1> to selectFunction : PatternSelectFunction<IN,OUT1> in method public createTimeoutPatternStream(inputStream DataStream<IN>, pattern Pattern<IN,?>, comparator EventComparator<IN>, selectFunction PatternSelectFunction<IN,OUT1>, outTypeInfo TypeInformation<OUT1>, outputTag OutputTag<OUT2>, timeoutFunction PatternTimeoutFunction<IN,OUT2>, lateDataOutputTag OutputTag<IN>) : SingleOutputStreamOperator<OUT1> in class org.apache.flink.cep.operator.CEPOperatorUtils |
From |
To |