Skip to content

Commit

Permalink
[feat] update readme.md
Browse files Browse the repository at this point in the history
Signed-off-by: tiezhu <[email protected]>
  • Loading branch information
FlechazoW committed Jun 30, 2021
1 parent e8abbb6 commit 586084f
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 17 deletions.
23 changes: 6 additions & 17 deletions core/src/main/java/com/dtstack/flink/sql/side/BaseSideInfo.java
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,12 @@
import com.google.common.base.Preconditions;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
import org.apache.calcite.sql.*;
import org.apache.calcite.sql.JoinType;
import org.apache.calcite.sql.SqlBasicCall;
import org.apache.calcite.sql.SqlIdentifier;
import org.apache.calcite.sql.SqlKind;
import org.apache.calcite.sql.SqlLiteral;
import org.apache.calcite.sql.SqlNode;
import org.apache.calcite.util.NlsString;
import org.apache.flink.api.java.typeutils.RowTypeInfo;
import org.apache.flink.table.runtime.typeutils.BaseRowTypeInfo;
Expand Down Expand Up @@ -218,22 +223,6 @@ private void checkSupport(SqlIdentifier identifier) {
Preconditions.checkState(isSide, errorMsg);
}

private void checkSupport(SqlIdentifier identifier) {
String tableName = identifier.getComponent(0).getSimple();
String sideTableName;
String sideTableAlias;
if (joinInfo.isLeftIsSideTable()) {
sideTableName = joinInfo.getLeftTableName();
sideTableAlias = joinInfo.getLeftTableAlias();
} else {
sideTableName = joinInfo.getRightTableName();
sideTableAlias = joinInfo.getRightTableAlias();
}
boolean isSide = tableName.equals(sideTableName) || tableName.equals(sideTableAlias);
String errorMsg = "only support set side table constant field, error field " + identifier;
Preconditions.checkState(isSide, errorMsg);
}

private void associateField(String sourceTableField, String sideTableField, SqlNode sqlNode) {
String errorMsg = "can't deal equal field: " + sqlNode;
equalFieldList.add(sideTableField);
Expand Down
5 changes: 5 additions & 0 deletions docs/quickStart.md
Original file line number Diff line number Diff line change
@@ -1,3 +1,8 @@
# 通知!!!
因该项目与FlinkX项目合并统一,即 2021-07-01 起, 1.12.x 版本之后,项目迁移到 FlinkX 项目中。

FlinkStreamSQL 项目推荐使用版本 1.10_release(为最新稳定版本)。

### 1.1 运行模式

* 本地模式:通常用于本地开发调试(--mode:local)
Expand Down

0 comments on commit 586084f

Please sign in to comment.