legotime的博客

flink扫盲-实验环境搭建与入门写作缘由flink 入门实验更多配置信息 写作缘由 从flink的Github 介绍我们可以得到如下信息： Apache Flink is an open source stream processing framework with powerful stream- and batch-processing capabilities. 可以看出，它主推的两个...

文章目录基本信息数据源x从何而来?直接输入形式Socket形式文件形式自定义的方式处理规则f(x)有哪些?(transformations)数据y可以存放何处(Data sinks)实验环境附录pom.xml文件 搭建环境然后运行完 helloworld 实验之后，接下来我们就要聊聊flink的数据处理了。对于数据处理，我们可以从人人都熟悉的函数关系式y = f(x)开始聊起。单从函数关系式来讲：...

文章目录直接输入形式fromElementsfromCollectionSocket形式文件形式自定义形式 下面针对DataStream中数据流向API的数据源进行实验 直接输入形式 fromElements step1:编写程序 ElementsInput.java package org.myorg.quickstart; import org.apache.flink.streaming....