栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Flink-Sql执行所需依赖2.0v

Flink-Sql执行所需依赖2.0v

哈哈哈,你永远不知道回踩多少坑啊!!!
改天吧报错信息总结一下
这边这篇依赖相对挺全了,好歹能直接看出效果了



    4.0.0

    org.example
    bhfae_flink_sql
    1.0-SNAPSHOT

    
        8
        8
    

    
        
            
                org.apache.maven.plugins
                maven-compiler-plugin
                
                    8
                    8
                
            
        
    

    
    
        org.apache.flink
        flink-table-api-java-bridge_2.11
        1.11.2

    

    
        org.apache.flink
        flink-table-planner_2.11
        1.11.2

    
    
    
        org.apache.flink
        flink-table-planner-blink_2.11
        1.11.2

    


        
        
            org.apache.flink
            flink-json
            1.11.0
        
        
            com.fasterxml.jackson.core
            jackson-databind
            2.9.8
        

        
        joda-time
        joda-time
        2.10.1
        

        
            org.apache.flink
            flink-clients_2.11
            1.11.2
        

    


我的测试代码:

 StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        EnvironmentSettings settings = EnvironmentSettings.newInstance().useBlinkPlanner().inStreamingMode().build();
        StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env, settings);

        String sql="CREATE TABLE Orders (`business_time` STRING, `prod_name` STRING, `product_type` STRING,`vol` Double,`batch_time` TIMESTAMP)WITH ( 'connector' = 'filesystem','path' = 'D:\杂文件/sql.txt','format' = 'json')";

        TableResult tableResult = tableEnv.executeSql(sql);

        String sql2="SELECt business_time,prod_name FROM Orders ";
        Table result = tableEnv.sqlQuery(sql2);

        result.execute().print();

我是可以查出来结果的,希望对大家有所帮助。

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/583278.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号