用户组:游客
问题导读 1.为什么说Flink是高性能? 2.什么是Flink状态计算? 3.Flink如何实现容错的? 4.Flink为何要内存管理? 5.Flink中 ...
问题导读 1.流处理和批处理分别入口是什么? 2.对于本地和远程运行程序,都可以使用哪个函数? 3.Flink数据源分为哪两类? ...
问题导读 1.ssh安装需要注意什么问题? 2.Flink集群配置文件是哪个? 3.Flink常用配置参数的含义是什么? 4.如何具体配置某 ...
问题导读 1.Flink中Map函数和FlatMap函数有什么区别? 2.如何生成KeyedStream? 3.KeyedStream如何转换为DataStream ? 4.min ...
问题导读 1.如何在window下安装Flink? 2.Flink本地安装启动命令与原先版本有什么区别? 3.window和Linux本地启动命令有什么区 ...
问题导读 1.Flink程序结是什么结构? 2.Flink中source,sink分别是什么意思? 2.Flink数据源有哪些? 3.如何自定义Flink数 ...
问题导读 1.Flink有哪三种运行模式? 2.Flink架构有几层? 3.Flink每层的作用是什么? 4.JobGraph是什么? 5.executiongraph ...
问题导读 1.Flink提交到运行程序涉及哪些进程? 2.Flink slot是什么? 3.Job客户端是不是Flink内部部分,它的作用是什么? 4 ...
问题导读 1.动态表有什么特点? 2.流处理与批处理有什么相同之处? 3.动态表和连续查询的关系? 4.连续查询本文列举了什么例 ...
问题导读 1.Flink有哪两个关系API? 2.Table API有那两种语言? 3.Table API和SQL接口彼此集成的好处是什么? 4.DataStrea ...
问题导读 1.Flink表的类型有哪几种? 2.API与SQL客户端分别什么方式指定连接器? 3.Scala和Java如何创建连接器? 4.YAML配 ...
问题导读 1.DataStream和DataSet转换为Table有几种方式? 2.如何将DataStream和DataSet注册为表? 3.如何转换DataStream 或 ...
问题导读 1.Flink中可以使用Hadoop哪些内容? 2.Hadoop InputFormat在Flink中视为什么? 3.FlatMapFunction与Hadoop哪一 ...
问题导读 1.为何产生window窗口计算? 2.你认为什么情况下使用Window Apply? 3.Window Fold可以用来做什么? 4.window 流 ...
问题导读 1.事件时间、处理时间、提取时间的顺序是什么? 2.事件时间为何需要水印? 3.处理时间是否提取的当前系统的时间? ...
问题导读 1.独立模式有哪些条件? 2.循环模式模式该如何停止? 3.subtype的作用是什么? 上一篇: Flink难点:彻底明 ...
问题导读 1.窗口是什么时候开始创建的? 2.窗口删除是什么时候? 3.如何延迟窗口删除? 4.Keyed和Non-Keyed Windows有什么 ...
问题导读 1.Flink有哪些内置连接器? 2.Flink二进制发布包中是否直接可以使用连接器? 3.如何才能添加连接器? 4.连接器使 ...
问题导读 1.如何实现Flink流分区? 2.对于数据倾斜,该使用什么函数实现数据均衡? 3.Rescaling与rebalance有什么区别? ...
本帖最后由 levycui 于 2020-6-10 19:39 编辑 问题导读: 1、如何使用 Maven 构建的 Flink 项目? 2、如何进行common module ...
问题导读 1.Flink如何获取各种不同格式的文件,转换为dataset? 2.Flink sources有哪些类型? 3.Flink是否可以读取压缩文件 ...
问题导读 1.DataSet 有哪些内置Sink? 2.Flink Sink的作用是什么? 3.DataSet 输出数据如何实现本地排序? 4.Sink是否支持 ...
问题导读 1.通过什么操作,可以实现定义模式开始? 2.如果事件之间严格连续,需要使用哪个函数? 3.宽松模式该如何实现? ...
问题导读 1.PatternProcessFunction是哪个版本引入的? 2.对于模式检测中超时部分处理使用什么接口? 3.如何创建PatternStr ...
问题导读 1.输出模式包含哪两种? 2.输出行的schema包含哪些列? 3.什么是模式变量? 上一篇:彻底明白Flink系统学习29- ...
问题导读 1.Flink事件流如何匹配? 2.MATCH_RECOGNIZE子句的作用是什么? 3.如何才能使用MATCH_RECOGNIZE子句? 4.MATCH_RE ...
问题导读 1.什么是Flink时态表? 2.时态表有什么特点? 3.如何创建时态表? 4.时态表产生的原因是什么? 上一篇彻底明 ...
问题导读 1.Flink CEP解决什么问题? 2.如何使用Flink CEP 3.CEP有哪些模式? 4.CEP量词的作用是什么? 5.本文讲了哪些量 ...
问题导读 1.对于接受事件该如何实现过滤? 2.CEP都有哪些条件? 3.迭代条件和简单条件有什么区别? 4.如何组合条件? ...
问题导读 1.Flink sql程序结构包含哪些内容? 2.TableEnvironment的作用是什么? 3.如何创建TableEnvironment? 4.如何注 ...
本版积分规则 发表帖子
查看 »