用户组:游客
问题导读: 1、Flink集群有哪些组件? 2、Flink Slot与Job运行的关系有哪些? 3、如何理解Slot Sharing? 4、迁移OnYarn后Jo ...
问题导读 1.写成的监控体系存在哪些问题? 2.为什么最终选择了 Flink? 3.Prophet 操作流程是怎样的? Flink 已经 ...
问题导读 1.什么是CEP? 2.CEP解决什么问题? 3.CEP如何实现? Flink CEP是比较难以理解的,那么它是什么?它解决了什 ...
问题导读: 1、如何理解Apache Flink 的架构及原理? 2、如何理解「有状态的流式处理」概念解析? 3、Apache Flink 的优势有 ...
问题导读 1.checkpoint的作用是什么? 2.两步提交的步骤包含哪些? 3.如何实现两步提交? 我们知道exactly-once,大多知 ...
问题导读 1.什么是量词? 2.量词的作用是什么? 3.greedy()的作用是什么? 4.如果事件可以不发生,该使用什么量词来表示 ...
本帖最后由 pig2 于 2019-5-27 16:59 编辑 问题导读 1.Flink二进制包中是否包含连接器? 2.Flink二进制包中是否包含相关库 ...
问题导读 1.Watermarks是什么? 2.Watermarks是为了解决什么问题? 3.如何生成watermarks? 最新经典文章,欢迎关注公众 ...
问题导读 1.IDEA社区版如何import项目? 2.项目导入中,该如何选择避免找不到相关包? 3.导入的过程中,有哪些需要注意的? ...
问题导读 1.FlinkCEP是什么? 2.FlinkCEP解决了什么问题? 3.FlinkCEP该如何使用? 0. 本文概述简介 FlinkCEP是在Fli ...
问题导读 1.DataSet 有哪些内置Sink? 2.Flink Sink的作用是什么? 3.DataSet 输出数据如何实现本地排序? 4.Sink是否支持 ...
问题导读 1.Flink如何获取各种不同格式的文件,转换为dataset? 2.Flink sources有哪些类型? 3.Flink是否可以读取压缩文件 ...
问题导读 1.DataSet与 Datastream Transformations 都有哪些API? 2.DataSet MapPartition的作用是什么? 3.ReduceGroup与Red ...
问题导读 1.窗口是什么时候开始创建的? 2.窗口删除是什么时候? 3.如何延迟窗口删除? 4.Keyed和Non-Keyed Windows有什么 ...
本帖最后由 levycui 于 2019-5-7 19:00 编辑 问题导读: 1、Group Aggregate优化技巧有哪些? 2、如何定制高效去重方案? 3 ...
问题导读 1.什么是Pulsar? 2.Pulsar都有哪些概念? 3.Pulsar有什么特点? 4.Flink未来如何与Pulsar整合? Apache F ...
问题导读 1.Pulsar的topic是什么结构? 2.Pulsar支持哪三种订阅类型? 3.Pulsar租户是什么? Pulsar我们或许听说过 ...
本帖最后由 BGnv5 于 2019-5-4 11:38 编辑 问题导读 1.G7是如何工作的?2.G7的业务场景是怎样的?3.哪一种流计算框架比较适 ...
问题导读 1.在Kubernetes上运行Flink有哪些挑战? 2.为何我们选择将Flink作为作业集群运行? 3.在Kubernetes上是否可以运 ...
问题导读 1.Flink1.8引入对什么状态的连续清理? 2.保存点兼容性方面,不在兼容哪个版本? 3.Maven依赖在Hadoop方便发生了 ...
问题导读 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.Flink表格式都支持哪些格式? 2.Flink表格式都改如何定义和使用? 3.Flink提供的额外哪些TableSource和TableSinks ...
问题导读 1.流处理和批处理是否使用同一套table API? 2.是否所有算子都可以用于流处理和批处理? 3.本文讲了哪些聚合算子 ...
问题导读 1.Flink表的类型有哪几种? 2.API与SQL客户端分别什么方式指定连接器? 3.Scala和Java如何创建连接器? 4.YAML配 ...
问题导读 1.有界批量输入还是无界流输入,表API和SQL查询都有什么特点? 2.状态的本质是什么? 3.连续查询的准确性和资源消 ...
问题导读 1.LAST函数作用是什么? 2.FIRST函数的作用是什么? 3.LAST和FIRST函数使用有哪些需要注意的? 上一篇: 彻底 ...
问题导读 1.输出模式包含哪两种? 2.输出行的schema包含哪些列? 3.什么是模式变量? 上一篇:彻底明白Flink系统学习29- ...
问题导读 1.匹配模式有哪些匹配策略? 2.MATCH_RECOGNIZE子句是否可以使用已配置的状态保留时间? 3.匹配模式有哪些不支持 ...
本版积分规则 发表帖子
查看 »