本篇文章为大家展示了Flink开发怎样进行实时处理应用程序，内容简明扼要并且容易理解，绝对能使你眼前一亮，通过这篇文章的详细介绍希望你能有所收获。JDK：1.8Maven：3.6.1（最低Maven 3.0.4）使用上一节中的springboot-flink-train项目第一步：创建流处理上下文环境第二步：读取数据，使用socket流方式读取数据第三步：transform这里我们使用逗号分隔，然后跟批处理不同的是，这里使用keyBy(0) 香港云主机，而不是groupBy(0)。timewindow表示每隔多久执行一次。第四步：执行整体代码如下：首先在192.168.152.45上运行命令然后在运行main方法。在192.168.152.45的nc上输入在idea控制台输出如下：这个前面的”4>”表示并行度。我们可以设置setParallelism(1)来忽略这个问题。如下所示：这样控制台的打印结果如下：这样一个简单的demo就成功了！上面的代码中localhost与port需要用参数传递进来。代码如下：使用Flink提供的ParameterTool来接收参数。我们在运行时就可以指定参数列表了，其中的key必须以“-”或者“–”开头。在运行时，配置参数：这样运行就可以从外界传递参数了接下来使用Scala方式实现，在项目springboot-flink-train-scala中新建StreamingWCScalaApp，内容如下：这种方式比java实现更加简洁。上述内容就是Flink开发怎样进行实时处理应用程序，你们学到知识或技能了吗？如果还想学到更多技能或者丰富自己的知识储备，欢迎关注开发云行业资讯频道。
相关推荐: ASP.NET基于原生html标签的无序列表方法
这篇文章主要介绍了ASP.NET基于原生html标签的无序列表方法的相关知识，内容详细易懂，操作简单快捷，具有一定借鉴价值，相信大家阅读完这篇ASP.NET基于原生html标签的无序列表方法文章都会有所收获，下面我们一起来看看吧。在网页开发中，经常要用到无序列…
免责声明：本站发布的图片视频文字，以转载和分享为主，文章观点不代表本站立场，本站不承担相关法律责任；如果涉及侵权请联系邮箱：360163164@qq.com举报，并提供相关证据，经查实将立刻删除涉嫌侵权内容。
微信扫一扫 
