import org.apache.flink.table.api.EnvironmentSettings;
import org.apache.flink.table.api.SqlDialect;
import org.apache.flink.table.api.TableEnvironment;
import org.apache.flink.table.api.internal.TableEnvironmentImpl;
import org.apache.flink.table.delegation.Parser;
import org.apache.flink.table.operations.Operation;
import org.apache.flink.table.operations.ddl.CreateCatalogOperation;
import org.apache.flink.table.operations.ddl.CreateDatabaseOperation;
public class DDLParser {
static EnvironmentSettings settings;
static TableEnvironment tableEnvironment;
static TableEnvironmentImpl tableEnvironmentImpl;
static {
settings = EnvironmentSettings.newInstance()
.useBlinkPlanner()
.build();
tableEnvironment = TableEnvironment.create(settings);
tableEnvironmentImpl = ((TableEnvironmentImpl) tableEnvironment);
}
public static Operation parse(String ddl,SqlDialect dialect){
tableEnvironmentImpl.getConfig().setSqlDialect(dialect);
Parser parser = tableEnvironmentImpl.getParser();
return parser.parse(ddl).get(0);//如果ddl没问题,这里不会抛出异常
}
public static Operation parseHive(String ddl){
return parse(ddl, SqlDialect.HIVE);
}
public static Operation parseDefault(String ddl){
return parse(ddl, SqlDialect.DEFAULT);
}
}
判断Operation是哪个类型可以用instance of 来判断:
if(operation instanceof CreateDatabaseOperation){
}
if (operation instanceof CreateCatalogOperation){
}
if (operation instanceof CreateTableOperation){
}
//其他。。。。。。。。。。
|