开发者社区> 问答> 正文

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

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

展开
收起
李博 bluemind 2018-11-15 10:56:35 2513 0
1 条回答
写回答
取消 提交回答
  • 云栖社区Java、Redis、MongoDB运营小编,有意合作请联系钉钉:15810436147

    阿里云实时计算 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;
    2019-07-17 23:14:19
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载