-
Notifications
You must be signed in to change notification settings - Fork 60
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
11 changed files
with
81 additions
and
119 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Large diffs are not rendered by default.
Oops, something went wrong.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -5,6 +5,4 @@ | |
--- | ||
###### [1、Flink中ExecutionEnvironment初始化流程?]() | ||
|
||
|
||
###### [2、用过DataSet里面的哪些方法?]() | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
@@ -1,28 +1,20 @@ | ||
|
||
|
||
* [FlinkSQL]() | ||
- [1)、Flink sql简介?]() | ||
- [2)、Flink sql join?]() | ||
- [3)、Flink内部的SQL引擎模块?]() | ||
|
||
|
||
###### [1)、Flink sql简介?]() | ||
Flink Table & SQL API是在DataStream和DataSet之上封装的一层高级API。 | ||
|
||
###### [2)、Flink sql join?]() | ||
|
||
|
||
###### [3)、Flink内部的SQL引擎模块?]() | ||
Calcite作为一个强大的SQL计算引擎,在Flink内部的SQL引擎模块就是基于Calcite。 | ||
|
||
Table & SQL API基于scala和java编写,内部基于calcite实现标准sql的解析和校验。跟spark不一样,flink直接基于开源的calcite编写。 | ||
calcite本身是一个apache的开源项目,它独立于存储和执行,专门负责sql的解析优化、语法树的校验等,并且通过插件的方式可以很方便的扩展优化规则,广泛的应用在hive、solr、flink等中。 | ||
|
||
###### [4)、Flink sql优化?]() | ||
|
||
|
||
###### [5)、Flink sql常用算子函数有哪些?]() | ||
|
||
|
||
###### [6)、Flink sql工作流?]() | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -705,7 +705,6 @@ | |
return _instance; | ||
} | ||
|
||
|
||
###### [60)、Java map的containsKey实现?]() | ||
|
||
###### [61)、java字符串contains实现原理?]() | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -253,7 +253,5 @@ | |
|
||
###### [37)、Kafka 数据存储类型?]() | ||
|
||
|
||
###### [38)、Kafka 选举策略?]() | ||
|
||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -68,4 +68,3 @@ | |
4)、build-info 生成执行器可以使用的构造信息。 | ||
|
||
###### [8、SpringBoot多线程实现?]() | ||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Original file line number | Diff line number | Diff line change |
---|---|---|
|
@@ -138,12 +138,6 @@ | |
1).逻辑查询计划优化 | ||
2).转换成DataStream程序 | ||
|
||
|
||
###### [13、查询优化,Old planner?]() | ||
|
||
|
||
|
||
###### [14、查询优化,Blink planner?]() | ||
|
||
|
||
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters