StreamingPro支持Flink的流式计算了

  • 时间:
  • 浏览:2
  • 来源:大发5分排列5_极速5分排列3

有的过后亲们过后我按条处置,追求实时性而非吞吐量的过后,这类Storm的模式就比较好了。Spark 在流式处置总是 过低改进,而Flink在流式方面做得很棒,两者高层的API也是互相借鉴,容易形成统一的感官,全都决定让StreamingPro适配Flink,让其作为StreamingPro底层的流式引擎。

StreamingPro自身设计之初全都为了支持多引擎的,全都改造成本很低,昨天花了一下午,晚加带了会班就重构完了。这次增强还还能否 我想司的流式引擎有了新的选者。

https://pan.baidu.com/s/1slCpxxV

过后写1个多多 flink.json文件:

你也还还能否 到localhost:3081 页面上提交你的任务。

过后皆还还能否 了。

接着全都下载StreamingPro的 flink版本:

下载安装包

的。

进入flink安装目录运行如下命令:

为了跑起来,你都要下载1个多多 flink的包,我用的是

目前source 只支持 kafka/socket ,Sink则只支持console和csv。准备好你你你这俩文件你就还还能否 提交任务了:

底下一句话

Flink目前在流式计算上对SQL支持有限,暂时还不支持Join,Agg等行为操作,你你你这俩和Spark相比较而言差距还比较大。不过亲们越来很快会将Script暴露出来,还还能否 让亲们直接进行编程,主要利用其Table API。