Toggle navigation
Home
org.apache.flink.streaming.api.datastream.DataStream to org.apache.flink.streaming.api.datastream.SingleOutputStreamOperator
No. of Instances - 62
No. of Commits - 4
No. of Projects - {'flink'}
Hierarchy/Composition: R_SUPER_T
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Add or Remove Method invocation
keyedStream.transform("KeyedCEPPatternOperator",(TypeInformation<Map<String,T>>)(TypeInformation<?>)TypeExtractor.getForClass(Map.class),new KeyedCEPPatternOperator<>(inputSerializer,isProcessingTime,keySelector,keySerializer,nfaFactory,true))
to
keyedStream.transform("KeyedCEPPatternOperator",(TypeInformation<Map<String,T>>)(TypeInformation<?>)TypeExtractor.getForClass(Map.class),new KeyedCEPPatternOperator<>(inputSerializer,isProcessingTime,keySelector,keySerializer,nfaFactory,lateDataOutputTag,true))
inputStream.keyBy(keySelector).transform("CEPPatternOperator",(TypeInformation<Map<String,T>>)(TypeInformation<?>)TypeExtractor.getForClass(Map.class),new KeyedCEPPatternOperator<>(inputSerializer,isProcessingTime,keySelector,keySerializer,nfaFactory,false)).forceNonParallel()
to
inputStream.keyBy(keySelector).transform("CEPPatternOperator",(TypeInformation<Map<String,T>>)(TypeInformation<?>)TypeExtractor.getForClass(Map.class),new KeyedCEPPatternOperator<>(inputSerializer,isProcessingTime,keySelector,keySerializer,nfaFactory,lateDataOutputTag,false)).forceNonParallel()
keyedStream.transform("TimeoutKeyedCEPPatternOperator",eitherTypeInformation,new TimeoutKeyedCEPPatternOperator<>(inputSerializer,isProcessingTime,keySelector,keySerializer,nfaFactory,true))
to
keyedStream.transform("TimeoutKeyedCEPPatternOperator",eitherTypeInformation,new TimeoutKeyedCEPPatternOperator<>(inputSerializer,isProcessingTime,keySelector,keySerializer,nfaFactory,lateDataOutputTag,true))
inputStream.keyBy(keySelector).transform("TimeoutCEPPatternOperator",eitherTypeInformation,new TimeoutKeyedCEPPatternOperator<>(inputSerializer,isProcessingTime,keySelector,keySerializer,nfaFactory,false)).forceNonParallel()
to
inputStream.keyBy(keySelector).transform("TimeoutCEPPatternOperator",eitherTypeInformation,new TimeoutKeyedCEPPatternOperator<>(inputSerializer,isProcessingTime,keySelector,keySerializer,nfaFactory,lateDataOutputTag,false)).forceNonParallel()
Cascading Type Change (Different)
TimeoutKeyedCEPPatternOperator<T,K>
to
TimeoutKeyedCEPPatternOperator<>