Skip to content

Commit

Permalink
Update README.md
Browse files Browse the repository at this point in the history
  • Loading branch information
HamaWhiteGG authored Apr 11, 2023
1 parent 45585bb commit 7e56ba5
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -432,7 +432,7 @@ public TableResult execute(String username, String singleSql) {
> 注: Flink版本1.16依赖的Calcite是1.26.0版本。
### 5.1 用[manifold-ext](https://github.com/manifold-systems/manifold/tree/master/manifold-deps-parent/manifold-ext) 扩展Flink ParserImpl类

新建包`extensions.org.apache.flink.table.planner.delegation.ParserImpl`注意extensions后面的包名称要等于Flink源码中ParserImpl类的包名.类名。
新建包`extensions.org.apache.flink.table.planner.delegation.ParserImpl`注意extensions后面的包名称要等于Flink源码中ParserImpl类的`包名.类名`
然后新建`ParserImplExtension`类来给`ParserImpl`类扩展`parseExpression(String sqlExpression)``parseSql(String)`两个方法。

```java
Expand Down Expand Up @@ -481,7 +481,7 @@ public class ParserImplExtension {
```

### 5.2 新增RowFilterVisitor类
新增上文提到的`addCondition()``addPermission()``buildWhereClause()`方法,同时新增`visit(SqlCall call)`方法来遍历AST中所有的SqlSelect对象重新生成Where子句`visit`方法如下,其他详见源码。
新增上文提到的`addCondition()``addPermission()``buildWhereClause()`方法,同时新增`visit(SqlCall call)`方法来遍历AST中所有的SqlSelect对象来重新生成Where子句`visit`方法如下,其他详见源码。
```java
@Override
public Void visit(SqlCall call) {
Expand Down

0 comments on commit 7e56ba5

Please sign in to comment.