今天就跟大家聊聊有关Flink中指定算子的方式是什么，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收获。
创新互联是一家专业的成都网站建设公司，我们专注成都网站制作、成都网站建设、网络营销、企业网站建设，买链接，一元广告为企业客户提供一站式建站解决方案，能带给客户新的互联网理念。从网站结构的规划UI设计到用户体验提高，创新互联力求做到尽善尽美。
我们之前在使用flatMap时，传了一个new FlatMapFunction匿名内部类。而这仅仅是其中的一种方式。
方式一：实现MapFunction接口
最简单的方式就是实现一个MapFunction接口，例如：
text.flatMap(new MyFlatMapFunction()).keyBy(new KeySelector() {
@Override
public Object getKey(WC value) throws Exception {
return value.word;
}
}).timeWindow(Time.seconds(5)).sum("count").print().setParallelism(1);
public static class MyFlatMapFunction implements FlatMapFunction {
@Override
public void flatMap(String value, Collector out) throws Exception {
String[] tokens = value.toLowerCase().split(",");
for (String token : tokens) {
if (token.length() > 0) {
out.collect(new WC(token, 1));
}
}
}
}
方式二：匿名内部类
这种方式就是我们之前一直使用的方式。
方式三：java8 Lambdas
方式四：Rich functions
text.flatMap(new RichFlatMapFunction() {
@Override
public void flatMap(String value, Collector out) throws Exception {
String[] tokens = value.toLowerCase().split(",");
for (String token : tokens) {
if (token.length() > 0) {
out.collect(new WC(token, 1));
}
}
}
})
继承一个RichFlatMapFunction类
看完上述内容，你们对Flink中指定算子的方式是什么有进一步的了解吗？如果还想了解更多知识或者相关内容，请关注创新互联行业资讯频道，感谢大家的支持。
当前文章：Flink中指定算子的方式是什么
URL网址：
http://bzwzjz.com/article/jphsop.html
