Flink中MapFunction以及其他各种xxxFunction在intellij中的用法和规律

我们以MapFunction为例，来分析下这些xxxFunction的规律

可以看到new MapFunction后面的

另外注意，这里在这里敲入new MapFunction的时候，必须在等号左侧已经书写了DataStream<Tuple2<String,Integer>>result

否则会导致intellij在MapFunction中动态补充的代码中出现

MapFunction<String, Object>()

而不是MapFunction<String, Tuple2<String, Integer>>()

完整代码如下:

import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.api.java.tuple.Tuple;
import org.apache.flink.api.java.tuple.Tuple2;
import org.apache.flink.api.java.typeutils.runtime.kryo.JavaSerializer;
import org.apache.flink.streaming.api.TimeCharacteristic;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.AssignerWithPeriodicWatermarks;
import org.apache.flink.streaming.api.functions.windowing.WindowFunction;
import org.apache.flink.streaming.api.watermark.Watermark;
import org.apache.flink.streaming.api.windowing.time.Time;
import org.apache.flink.streaming.api.windowing.windows.Window;
import org.apache.flink.util.Collector;
import org.apache.flink.api.common.functions.ReduceFunction;import java.io.File;public class WindowReduce
{public static void main(String[] args) throws Exception{StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironment();env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);DataStream<String> dataStream = env.socketTextStream("Desktop", 9999);//        map的作用是
//返回的是什么，输入的是什么DataStream<Tuple2<String,Integer>>result=dataStream.map(new MapFunction<String, Tuple2<String, Integer>>() {@Overridepublic Tuple2<String, Integer> map(String s) throws Exception {return new Tuple2<String, Integer>(s,1) ;}});}}

Flink中MapFunction以及其他各种xxxFunction在intellij中的用法和规律相关推荐

flink sql 如何upsert 到一张hologres表中
Flink Table 的三种 Sink 模式作为计算引擎 Flink 应用的计算结果总要以某种方式输出,比如调试阶段的打印到控制台或者生产阶段的写到数据库.而对于本来就需要在 Flink 内存保存 ...
intellij中运行后出现Hadoop is not in the classpath/dependencies
intellij中运行check point的时候碰到了一个比较棘手的问题 Hadoop is not in the classpath/dependencies 版本: 组件版本号 Flink 1 ...
在php代码中加视频,php – 如何在laravel代码中嵌入视频
我正在开发一个项目,我将youtube视频链接存储在数据库中,然后我检索这些链接并使用刀片模板引擎我尝试将它们嵌入到页面中.我使用循环将视频放在页面中.出于某种原因,我没有在浏览器中收到任何视频.它覆 ...
java 是怎么在中删除下拉列表_删除在一个下拉列表字段中选择的选项，并且不显示在该行中存在的其他下拉列表中不工作-jquery...
我有一个包含多列的html表,在两列中我显示下拉列表 . 当用户从一个下拉列表中选择值时(选择Product1或Select Product2下拉列表),我想删除在一个下拉列表中选择的选项,并且不要在 ...
word文档怎么给数字加千分符_Word中如何将文档中的金额数值设置为财务数字中的千分位格式...
Word中如何将文档中的金额数值设置为财务数字中的千分位格式时间:2015-06-10 作者:snow 来源:互联网如图6‑19所示为某公司给省商务厅上报的2013年农产品现代流通综合试点 ...
利用lua中的string.gsub来巧妙实现json中字段的正则替换
业务需求工作中需要对某个请求的json响应中的某个字段进行替换, 通常想到的方法是,先使用lua的cjson模块解析该json响应, 取出该json字段再该改写它的值. 在这样实现的过程中,遇到一些 ...
HTML中常见的各种位置距离以及dom中的坐标讨论
最近在学习JavaScript,特意买了一本犀牛角书来看看,尼玛一千多页,看的我头昏脑涨,翻到DOM这章节,突然记起平常在使用DOM时,碰到了好多的这个dom里面的各种宽度,高度,特意在此写一写,写的 ...
版电力系统故障录波_电力系统中的变电运维技术匹配专业中的应用
电力系统中变电运维产生故障的主要原因分为两点: (1)人为因素.在变电运维工作的过程中,变电运维人员是其中的主体,其专业素质和责任意识直接决定着变电运维工作的整体质量,目前部分变电运维人员的安全意识和 ...
python中tensor与variable_NLP实战篇之tf2中tensor、variable、gradient、ops
本文是基于tensorflow2.2.0版本,介绍了tf中变量.张量的概念,tf中梯度的计算方式和tensor相关的操作. 实战系列篇章中主要会分享,解决实际问题时的过程.遇到的问题或者使用的工具等等 ...

Flink中MapFunction以及其他各种xxxFunction在intellij中的用法和规律

Flink中MapFunction以及其他各种xxxFunction在intellij中的用法和规律相关推荐

最新文章

热门文章