问题导读： 1、如何创建calcite logical Plan? 2、什么负责sql的parse和验证？ 3、FlinkRuleSets定义哪些rule？ 4、如何将Da ...

levycui 2019-1-15 0 13967

问题导读 1.Flink中Map函数和FlatMap函数有什么区别? 2.如何生成KeyedStream？ 3.KeyedStream如何转换为DataStream ？ 4.min ...

pig2 2018-12-5 7 13725

问题导读 1.Debezium和kafka是什么关系？ 2.Debezium有哪三种方式实现变化数据库捕获？ 3.如何实现注册Connector 去检测 mysq ...

hyj 2021-3-3 0 13582

问题导读 1.如何实现Flink流分区？ 2.对于数据倾斜，该使用什么函数实现数据均衡？ 3.Rescaling与rebalance有什么区别？ ...

pig2 2018-12-17 3 13420

问题导读 1.Flink CEP解决什么问题？ 2.如何使用Flink CEP 3.CEP有哪些模式？ 4.CEP量词的作用是什么？ 5.本文讲了哪些量 ...

pig2 2019-6-3 2 13129

问题导读 1.DataSet与 Datastream Transformations 都有哪些API？ 2.DataSet MapPartition的作用是什么？ 3.ReduceGroup与Red ...

pig2 2018-12-24 2 13041

问题导读 1.Flink 双数据流转换为单数据流操作有哪些？ 2.cogroup, join和coflatmap各自完成什么事情？ 3.cogroup, join和 ...

pig2 2018-12-24 1 12592

问题导读 1.动态表有什么特点？ 2.流处理与批处理有什么相同之处？ 3.动态表和连续查询的关系？ 4.连续查询本文列举了什么例 ...

pig2 2019-1-17 5 12539

问题导读 1.组合模式需要哪些函数？ 2.事件之间的关系有哪三种？ 3.循环模式如何表示？ 4.循环模式中默认是哪个模式？ ...

pig2 2019-6-12 2 12211

问题导读 1.对于接受事件该如何实现过滤？ 2.CEP都有哪些条件？ 3.迭代条件和简单条件有什么区别？ 4.如何组合条件？ ...

pig2 2019-6-10 2 12224

本帖最后由 林宝宝 于 2019-8-8 12:28 编辑 问题导读： 1.Flink自定义kudu的source和sink是如何实现的？ 2.flinkStreamSQL ...

林宝宝 2019-8-8 0 12195

问题导读： 1、用哪些衡量指标Flink性能？ 2、有哪些实时数据库查找关联 3、有哪些预加载维表关联？ 4、如何进行维表变更日 ...

levycui 2020-4-8 1 11916

本帖最后由 levycui 于 2020-7-22 11:18 编辑 问题导读： 1、如何配置 JobManager 内存？ 2、如何配置 JVM 堆内存？ 3、Fli ...

levycui 2020-7-22 0 11931

问题导读 1.Flink读写Clickhouse支持哪个版本？ 2.ClickHouse读写Clickhouse有哪些参数？ 3.ClickHouse读写Clickhouse参数 ...

admin 2020-8-4 0 11661

问题导读： 1、如何理解一致性语义？ 2、Storm、Sparkstreaming主要有哪些几个概念？ 3、为什么使用Flink及Flink有哪些特性？ ...

levycui 2018-8-14 1 11201

问题导读 1.什么是CEP？ 2.CEP解决什么问题？ 3.CEP如何实现？ Flink CEP是比较难以理解的，那么它是什么？它解决了什 ...

pig2 2019-6-24 0 11202

问题导读 1.集群搭建本文都说了哪些因素？ 2.什么情况下需要考虑网络容量？ 3.什么情况需要考虑磁盘宽带？ 4.除了6个因素 ...

pig2 2018-10-18 3 10851

问题导读 1.Flink如何获取各种不同格式的文件，转换为dataset？ 2.Flink sources有哪些类型？ 3.Flink是否可以读取压缩文件 ...

pig2 2018-12-26 2 10836

问题导读 1.Flink1.7开始支持Scala哪个版本？ 2.Flink1.7状态演变在实际生产中有什么好处？ 3.Streaming SQL支持MATCH_RECOGN ...

pig2 2018-12-1 1 10624

问题导读 1.什么是广播状态模式？？ 2.什么是广播状态？ 3.使用广播状态时要注意哪4个重要事项？ 关注最新经典文章， ...

pig2 2018-11-12 4 10404

问题导读 1.Savepoints和Checkpoints是什么？ 2.Savepoints和Checkpoints有哪三点区别？ 3.何时在流应用程序中使用Savepoi ...

pig2 2018-11-7 2 10393

本帖最后由 hero1122 于 2017-7-10 18:57 编辑 问题导读: 1.Flink的集群架构是怎么样的？ 2.使用Flink执行wordCount操作并且 ...

hero1122 2017-7-10 1 10178

问题导读 1.匹配跳过策略的作用是什么？ 2.匹配跳过策略有哪四种？ 3.匹配跳过策略代码如何实现？ 上一篇 Flink难点： ...

pig2 2019-6-17 2 10230

问题导读 1.Pulsar的topic是什么结构？ 2.Pulsar支持哪三种订阅类型？ 3.Pulsar租户是什么？ Pulsar我们或许听说过 ...

pig2 2019-5-5 1 10179

本帖最后由 levycui 于 2019-5-7 19:00 编辑 问题导读： 1、Group Aggregate优化技巧有哪些？ 2、如何定制高效去重方案？ 3 ...

levycui 2019-5-7 0 10051

问题导读 1.PatternProcessFunction是哪个版本引入的？ 2.对于模式检测中超时部分处理使用什么接口？ 3.如何创建PatternStr ...

pig2 2019-6-17 2 9971

问题导读 1.为何产生window窗口计算？ 2.你认为什么情况下使用Window Apply？ 3.Window Fold可以用来做什么？ 4.window 流 ...

pig2 2018-12-10 3 9891

问题导读 1.Flink sql程序结构包含哪些内容？ 2.TableEnvironment的作用是什么？ 3.如何创建TableEnvironment？ 4.如何注 ...

pig2 2019-1-10 2 9737

本帖最后由 pig2 于 2019-1-21 11:22 编辑 问题导读 1.Table和SQL API如何定义时间属性？ 2.如何将时间属性嵌入到Table和SQL ...

pig2 2019-1-21 1 9669