- import org.apache.flink.table.api.EnvironmentSettings;
- import org.apache.flink.table.api.TableEnvironment;
- public final class xxx(类名，jar包名称){
- public WordCountSQLExample() {
- }
- public static void main(String[] args) throws Exception {
- //创建flink运行环境
- EnvironmentSettings settings = EnvironmentSettings.newInstance().inBatchMode().build();
- //创建flink-table运行环境
- TableEnvironment tableEnv = TableEnvironment.create(settings);
- //tableEnv.executeSql（” 写入sql语句 “）
- tableEnv.executeSql(“SELECT word, SUM(frequency) AS `count`\nFROM (\n VALUES (‘Hello’, 1), (‘Ciao’, 1), (‘Hello’, 2)\n)\nAS WordTable(word, frequency)\nGROUP BY word”).print(); }
- }
作者 admin
张宴银，大数据开发工程师