用户组:游客
上一篇:flink实践:图解flink sql应用提交方式(一) 问题导读: 1、什么是Calcite? 2、Blink Planner怎样与Calcite进 ...
问题导读: 1、Flink Sql解析器是什么? 2、Flink Planner 和 Blink Planner如何理解? 3、Calcite的 parse 解析模块是基于什 ...
问题导读: 1、Flink 内存数据结构如何理解? 2、网络缓冲器(NetworkBuffer)是什么? 3、Flink 内存如何进行调优? 4、故障 ...
本帖最后由 levycui 于 2021-3-24 19:07 编辑 问题导读: 1、什么是Hive Catalog? 2、如何使用Hive Catalog? 3、什么是Hi ...
问题导读: 1、StreamTask的层级结构如何理解? 2、StreamTask生命周期的抽象方法如何实现? 3、Java泛型类型擦除如何实现? ...
问题导读: 1.StreamOperator是什么接口? 2.AbstractStreamOperator是什么抽象实现类? 3.StreamOperator继承哪些接口? ...
问题导读 1.Flink中的组件是怎样交互的? 2.Flink任务的处理流程是怎样的? 3.Flink各个节点之间是如何进行传递的? ...
本帖最后由 levycui 于 2020-7-22 11:18 编辑 问题导读: 1、如何配置 JobManager 内存? 2、如何配置 JVM 堆内存? 3、Fli ...
本帖最后由 levycui 于 2020-7-21 15:21 编辑 问题导读: 1、如何配置 Flink 进程的内存? 2、如何配置总内存? 3、如何配 ...
本帖最后由 levycui 于 2020-6-10 19:39 编辑 问题导读: 1、如何使用 Maven 构建的 Flink 项目? 2、如何进行common module ...
问题导读: 1、如何找到Task对应的SubTask1在哪台机器的哪个进程执行? 2、如何访问rest api获取Task的vertice id? 3、如何 ...
问题导读 1.对于事件延迟,cep是如何处理的? 2.对于cep编程,本文举了一个什么例子? 3.从较旧的Flink版本迁移有哪些需要 ...
问题导读 1.PatternProcessFunction是哪个版本引入的? 2.对于模式检测中超时部分处理使用什么接口? 3.如何创建PatternStr ...
问题导读 1.匹配跳过策略的作用是什么? 2.匹配跳过策略有哪四种? 3.匹配跳过策略代码如何实现? 上一篇 Flink难点: ...
问题导读 1.通过什么操作,可以实现定义模式开始? 2.如果事件之间严格连续,需要使用哪个函数? 3.宽松模式该如何实现? ...
问题导读 1.组合模式需要哪些函数? 2.事件之间的关系有哪三种? 3.循环模式如何表示? 4.循环模式中默认是哪个模式? ...
问题导读 1.独立模式有哪些条件? 2.循环模式模式该如何停止? 3.subtype的作用是什么? 上一篇: Flink难点:彻底明 ...
问题导读 1.对于接受事件该如何实现过滤? 2.CEP都有哪些条件? 3.迭代条件和简单条件有什么区别? 4.如何组合条件? ...
问题导读 1.Flink CEP解决什么问题? 2.如何使用Flink CEP 3.CEP有哪些模式? 4.CEP量词的作用是什么? 5.本文讲了哪些量 ...
问题导读 1.FlinkCEP是什么? 2.FlinkCEP解决了什么问题? 3.FlinkCEP该如何使用? 0. 本文概述简介 FlinkCEP是在Fli ...
问题导读 1.翻滚窗口如何定义时间长度? 2.关键字on一般是定义什么? 3.滑动窗口都是如何定义长度、间隔? 4.会话窗口间隔 ...
本帖最后由 pig2 于 2019-3-5 18:25 编辑 问题导读 1.OrderBy, Offset & Fetch作用是什么? 2.Insert可以干什么事情? 3.如 ...
本帖最后由 pig2 于 2019-2-28 11:51 编辑 问题导读 1.Join算子有哪些? 2.内联和外联有什么区别? 3.时间窗口连接有什么 ...
问题导读 1.流处理和批处理是否使用同一套table API? 2.是否所有算子都可以用于流处理和批处理? 3.本文讲了哪些聚合算子 ...
问题导读 1.Flink表格式都支持哪些格式? 2.Flink表格式都改如何定义和使用? 3.Flink提供的额外哪些TableSource和TableSinks ...
问题导读 1.Flink表的类型有哪几种? 2.API与SQL客户端分别什么方式指定连接器? 3.Scala和Java如何创建连接器? 4.YAML配 ...
问题导读 1.有界批量输入还是无界流输入,表API和SQL查询都有什么特点? 2.状态的本质是什么? 3.连续查询的准确性和资源消 ...
问题导读 1.匹配模式有哪些匹配策略? 2.MATCH_RECOGNIZE子句是否可以使用已配置的状态保留时间? 3.匹配模式有哪些不支持 ...
问题导读 1.LAST函数作用是什么? 2.FIRST函数的作用是什么? 3.LAST和FIRST函数使用有哪些需要注意的? 上一篇: 彻底 ...
问题导读 1.输出模式包含哪两种? 2.输出行的schema包含哪些列? 3.什么是模式变量? 上一篇:彻底明白Flink系统学习29- ...
本版积分规则 发表帖子
查看 »