用户组:游客
问题导读 1.ssh安装需要注意什么问题? 2.Flink集群配置文件是哪个? 3.Flink常用配置参数的含义是什么? 4.如何具体配置某 ...
上一篇: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.Flink有哪些内置连接器? 2.Flink二进制发布包中是否直接可以使用连接器? 3.如何才能添加连接器? 4.连接器使 ...
问题导读 1.Flink有哪三种运行模式? 2.Flink架构有几层? 3.Flink每层的作用是什么? 4.JobGraph是什么? 5.executiongraph ...
问题导读: 1、StreamTask的层级结构如何理解? 2、StreamTask生命周期的抽象方法如何实现? 3、Java泛型类型擦除如何实现? ...
问题导读: 1.StreamOperator是什么接口? 2.AbstractStreamOperator是什么抽象实现类? 3.StreamOperator继承哪些接口? ...
问题导读 1.Flink中的组件是怎样交互的? 2.Flink任务的处理流程是怎样的? 3.Flink各个节点之间是如何进行传递的? ...
本帖最后由 levycui 于 2020-6-10 19:39 编辑 问题导读: 1、如何使用 Maven 构建的 Flink 项目? 2、如何进行common module ...
本帖最后由 levycui 于 2020-7-22 11:18 编辑 问题导读: 1、如何配置 JobManager 内存? 2、如何配置 JVM 堆内存? 3、Fli ...
本帖最后由 levycui 于 2020-7-21 15:21 编辑 问题导读: 1、如何配置 Flink 进程的内存? 2、如何配置总内存? 3、如何配 ...
问题导读: 1、如何找到Task对应的SubTask1在哪台机器的哪个进程执行? 2、如何访问rest api获取Task的vertice id? 3、如何 ...
问题导读 1.事件时间、处理时间、提取时间的顺序是什么? 2.事件时间为何需要水印? 3.处理时间是否提取的当前系统的时间? ...
问题导读 1.Flink中Map函数和FlatMap函数有什么区别? 2.如何生成KeyedStream? 3.KeyedStream如何转换为DataStream ? 4.min ...
问题导读 1.如何实现Flink流分区? 2.对于数据倾斜,该使用什么函数实现数据均衡? 3.Rescaling与rebalance有什么区别? ...
问题导读 1.DataStream和DataSet转换为Table有几种方式? 2.如何将DataStream和DataSet注册为表? 3.如何转换DataStream 或 ...
问题导读 1.为何产生window窗口计算? 2.你认为什么情况下使用Window Apply? 3.Window Fold可以用来做什么? 4.window 流 ...
问题导读 1.流处理和批处理分别入口是什么? 2.对于本地和远程运行程序,都可以使用哪个函数? 3.Flink数据源分为哪两类? ...
问题导读 1.Flink提交到运行程序涉及哪些进程? 2.Flink slot是什么? 3.Job客户端是不是Flink内部部分,它的作用是什么? 4 ...
问题导读 1.如何在window下安装Flink? 2.Flink本地安装启动命令与原先版本有什么区别? 3.window和Linux本地启动命令有什么区 ...
问题导读 1.为什么说Flink是高性能? 2.什么是Flink状态计算? 3.Flink如何实现容错的? 4.Flink为何要内存管理? 5.Flink中 ...
问题导读 1.Flink程序结是什么结构? 2.Flink中source,sink分别是什么意思? 2.Flink数据源有哪些? 3.如何自定义Flink数 ...
问题导读 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难点:彻底明 ...
本版积分规则 发表帖子
查看 »