|
24 | 24 | import com.google.common.base.Preconditions; |
25 | 25 | import com.google.common.collect.Lists; |
26 | 26 | import com.google.common.collect.Maps; |
27 | | -import org.apache.calcite.sql.*; |
| 27 | +import org.apache.calcite.sql.JoinType; |
| 28 | +import org.apache.calcite.sql.SqlBasicCall; |
| 29 | +import org.apache.calcite.sql.SqlIdentifier; |
| 30 | +import org.apache.calcite.sql.SqlKind; |
| 31 | +import org.apache.calcite.sql.SqlLiteral; |
| 32 | +import org.apache.calcite.sql.SqlNode; |
28 | 33 | import org.apache.calcite.util.NlsString; |
29 | 34 | import org.apache.flink.api.java.typeutils.RowTypeInfo; |
30 | 35 | import org.apache.flink.table.runtime.typeutils.BaseRowTypeInfo; |
@@ -218,22 +223,6 @@ private void checkSupport(SqlIdentifier identifier) { |
218 | 223 | Preconditions.checkState(isSide, errorMsg); |
219 | 224 | } |
220 | 225 |
|
221 | | - private void checkSupport(SqlIdentifier identifier) { |
222 | | - String tableName = identifier.getComponent(0).getSimple(); |
223 | | - String sideTableName; |
224 | | - String sideTableAlias; |
225 | | - if (joinInfo.isLeftIsSideTable()) { |
226 | | - sideTableName = joinInfo.getLeftTableName(); |
227 | | - sideTableAlias = joinInfo.getLeftTableAlias(); |
228 | | - } else { |
229 | | - sideTableName = joinInfo.getRightTableName(); |
230 | | - sideTableAlias = joinInfo.getRightTableAlias(); |
231 | | - } |
232 | | - boolean isSide = tableName.equals(sideTableName) || tableName.equals(sideTableAlias); |
233 | | - String errorMsg = "only support set side table constant field, error field " + identifier; |
234 | | - Preconditions.checkState(isSide, errorMsg); |
235 | | - } |
236 | | - |
237 | 226 | private void associateField(String sourceTableField, String sideTableField, SqlNode sqlNode) { |
238 | 227 | String errorMsg = "can't deal equal field: " + sqlNode; |
239 | 228 | equalFieldList.add(sideTableField); |
|
0 commit comments