用户组:游客
问题导读 1.Flink sql程序结构包含哪些内容? 2.TableEnvironment的作用是什么? 3.如何创建TableEnvironment? 4.如何注 ...
问题导读 1.DataSet与 Datastream Transformations 都有哪些API? 2.DataSet MapPartition的作用是什么? 3.ReduceGroup与Red ...
问题导读 1.DataSet 有哪些内置Sink? 2.Flink Sink的作用是什么? 3.DataSet 输出数据如何实现本地排序? 4.Sink是否支持 ...
问题导读: 1、如何找到Task对应的SubTask1在哪台机器的哪个进程执行? 2、如何访问rest api获取Task的vertice id? 3、如何 ...
本帖最后由 pig2 于 2019-1-21 11:22 编辑 问题导读 1.Table和SQL API如何定义时间属性? 2.如何将时间属性嵌入到Table和SQL ...
问题导读: 1、Flink 内存数据结构如何理解? 2、网络缓冲器(NetworkBuffer)是什么? 3、Flink 内存如何进行调优? 4、故障 ...
问题导读 1.Flink有哪些连接? 2.常规连接、窗口连接、时态表连接有什么区别? 3.时态表函数如何使用? 上一篇彻底明白F ...
问题导读 1.本地执行分为那两种? 2.本地执行在程序方面有什么区别? 3.集群执行,如何连接master? 4.本地执行和集群执行 ...
问题导读 1.LAST函数作用是什么? 2.FIRST函数的作用是什么? 3.LAST和FIRST函数使用有哪些需要注意的? 上一篇: 彻底 ...
问题导读 1.Flink表格式都支持哪些格式? 2.Flink表格式都改如何定义和使用? 3.Flink提供的额外哪些TableSource和TableSinks ...
本帖最后由 pig2 于 2019-2-28 11:51 编辑 问题导读 1.Join算子有哪些? 2.内联和外联有什么区别? 3.时间窗口连接有什么 ...
问题导读 1.对于事件延迟,cep是如何处理的? 2.对于cep编程,本文举了一个什么例子? 3.从较旧的Flink版本迁移有哪些需要 ...
问题导读 1.Flink内置哪些文件系统? 2.Flink都支持哪些Hadoop版本? 3.Flink对Avro的支持,需要哪些工作? 上一篇 彻 ...
本帖最后由 pig2 于 2019-3-5 18:25 编辑 问题导读 1.OrderBy, Offset & Fetch作用是什么? 2.Insert可以干什么事情? 3.如 ...
问题导读 1.有界批量输入还是无界流输入,表API和SQL查询都有什么特点? 2.状态的本质是什么? 3.连续查询的准确性和资源消 ...
本帖最后由 pig2 于 2019-1-13 19:20 编辑 问题导读 1.Table API有哪两种语言? 2.你认为Table API包含哪些内容? 3.Flin ...
问题导读 1.如何创建不同数据类型的datastream? 2.数据类型映射分为哪两种? 3.基于位置的映射和基于名称的映射有什么区别 ...
问题导读 1.Flink中的组件是怎样交互的? 2.Flink任务的处理流程是怎样的? 3.Flink各个节点之间是如何进行传递的? ...
问题导读 1.FlinkCEP是什么? 2.FlinkCEP解决了什么问题? 3.FlinkCEP该如何使用? 0. 本文概述简介 FlinkCEP是在Fli ...
上一篇:flink实践:图解flink sql应用提交方式(一) 问题导读: 1、什么是Calcite? 2、Blink Planner怎样与Calcite进 ...
问题导读: 1、Flink Sql解析器是什么? 2、Flink Planner 和 Blink Planner如何理解? 3、Calcite的 parse 解析模块是基于什 ...
问题导读 1.翻滚窗口如何定义时间长度? 2.关键字on一般是定义什么? 3.滑动窗口都是如何定义长度、间隔? 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继承哪些接口? ...
本帖最后由 levycui 于 2020-7-22 11:18 编辑 问题导读: 1、如何配置 JobManager 内存? 2、如何配置 JVM 堆内存? 3、Fli ...
本帖最后由 levycui 于 2020-7-21 15:21 编辑 问题导读: 1、如何配置 Flink 进程的内存? 2、如何配置总内存? 3、如何配 ...
问题导读 1.匹配模式有哪些匹配策略? 2.MATCH_RECOGNIZE子句是否可以使用已配置的状态保留时间? 3.匹配模式有哪些不支持 ...
问题导读 1.流处理和批处理是否使用同一套table API? 2.是否所有算子都可以用于流处理和批处理? 3.本文讲了哪些聚合算子 ...
本版积分规则 发表帖子
查看 »