• 售前

  • 售后

热门帖子
入门百科

Flink从入门到放弃

[复制链接]
123457010 显示全部楼层 发表于 2022-1-13 09:12:23 |阅读模式 打印 上一主题 下一主题

前言

Flink是一个流批一体处理框架
官网链接:Flink官网

一、Flink初体验?

在IDEA上创建一个自己的flink程序
1.引入依赖库

代码如下(示例):
  1. <dependency>
  2.     <groupId>org.apache.flink</groupId>
  3.     <artifactId>flink-streaming-java_2.12</artifactId>
  4.     <version>1.12.7</version>
  5.     <!--            <scope>provided</scope>-->
  6. </dependency>
  7. <dependency>
  8.     <groupId>org.apache.flink</groupId>
  9.     <artifactId>flink-clients_2.12</artifactId>
  10.     <version>1.12.7</version>
  11. </dependency>
  12. <!-- https://mvnrepository.com/artifact/org.apache.flink/flink-core -->
  13. <dependency>
  14.     <groupId>org.apache.flink</groupId>
  15.     <artifactId>flink-core</artifactId>
  16.     <version>1.12.7</version>
  17.     <!--            <scope>provided</scope>-->
  18. </dependency>
复制代码
2.读入数据

代码如下(示例):本demo演示数据源为nc数据源
  1. StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
  2. DataStreamSource<String> source = env.socketTextStream("your IP", 10086);
  3. System.out.println("********************************************程序开始执行********************************************");
  4. source.print();
  5. env.execute("FirstFlinkApp");
复制代码
该处使用的url网络请求的数据。

3.结果展示 

数据输入:

 处理结果:


总结

本篇文章主要是flink初次体验,成功接收数据以及将数据打印在控制台
不知道大家发现没有,打印的数据前面有数字信息,这个信息是跟并行度有关,后面深度探究


来源:https://blog.caogenba.net/a18033860865/article/details/122434314
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!

帖子地址: 

回复

使用道具 举报

分享
推广
火星云矿 | 预约S19Pro,享500抵1000!
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

草根技术分享(草根吧)是全球知名中文IT技术交流平台,创建于2021年,包含原创博客、精品问答、职业培训、技术社区、资源下载等产品服务,提供原创、优质、完整内容的专业IT技术开发社区。
  • 官方手机版

  • 微信公众号

  • 商务合作