Flink 1.9CEP例子代码诠释【续】
本帖最后由 阿飞 于 2019-11-19 17:46 编辑问题导读
1.元组最大支持多少参数？
2.Flink CEP规则定义参数 begin、where、or、until、within等都在哪个包定义？
3.侧输出流该使用哪个类？
接上篇
Flink 1.9CEP例子代码诠释
https://www.aboutyun.com/forum.php?mod=viewthread&tid=28007
5. org.apache.flink.api.java.tuple.Tuple3
TupleTypeInfo任意的Flink tuple类型(支持Tuple1 to Tuple25)。 Flink tuples是固定长度固定类型的Java Tuple实现。
Tuple3的含义：
（1）三个参数的元组
（2）参数自定义
代码中Tuple3<String, String, String>，带表三个字符串类型的参数的元组。
6. org.apache.flink.cep.CEP工厂类
返回PatternStream对象
7. org.apache.flink.cep.PatternSelectFunction
定义select函数
8. org.apache.flink.cep.PatternStream（匹配流）
9. org.apache.flink.cep.PatternTimeoutFunction
超时处理接口
10. org.apache.flink.cep.pattern.Pattern
定义各种api包括： begin、where、or、until、within、next、followedBy、notFollowedBy、followedByAny、optional、oneOrMore、greedy、times、timesOrMore、allowCombinations、consecutive等函数
11.org.apache.flink.cep.pattern.conditions.IterativeCondition
定义filter、 TimeContext
12. org.apache.flink.streaming.api.environment.StreamExecutionEnvironment
StreamExecutionEnvironment是一个任务的启动的入口
13. org.apache.flink.streaming.api.windowing.time.Time
定义了milliseconds、seconds、minutes、hours、days
14. org.apache.flink.util.OutputTag
使用侧输出流时，首先定义一个OutputTag，这个OutputTag将用来标识一个侧输出流
15. java.util.List/java.util.Map;
java的集合框架为程序提供了一种处理对象组的标准方式。设计了一系列标准泛型接口：;
（1）List（）接口，扩展了Collection接口，存储一个序列的元素（列表基于0的索引），可以包含重复的元素，但不能有null值
（2）Map（映射）接口：映射是将键映射到值的对象，一个映射不能包含重复的键；每个键最多只能映射一个值。
###############end分割线
后续将录制为视频，加入星球可获取，已经录制视频。
https://www.aboutyun.com/data/attachment/forum/201911/18/171651puu4yzyrjjuyzy64.png
扫码可了解详情：
https://www.aboutyun.com/data/attachment/forum/201911/18/171932fttnxnq7n3j19w1e.jpg
页:
[1]