开发者社区> 问答> 正文

阿里云实时计算 Flink提供的编程接口是什么?如何编写流式数据处理逻辑?

李博 bluemind 2018-11-15 10:56:35 468

阿里云实时计算 Flink提供Flink SQL编写业务逻辑,为流式数据分析定制多种数据处理函数和操作符。

SQL 数据挖掘 数据处理 流计算
分享到
取消 提交回答
全部回答(1)
  • 李博 bluemind
    2019-07-17 23:14:19

    阿里云实时计算 Flink提供Flink SQL编写业务逻辑,为流式数据分析定制多种数据处理函数和操作符。以Word Count统计为例,下面给出一个具体的SQL例子。

    -- 声明一个流式源表
    create table stream_source(word string) ;
    -- 声明一个目标表
    create table stream_result(word string, cnt bigint) ;
    --统计word次数
    insert into stream_result
    select t.word,
           count(1)
    from stream_source t
    group by t.word;
    0 0
+ 订阅

大数据计算实践乐园,近距离学习前沿技术

推荐文章
相似问题
推荐课程