FlatMap算子：將數據流一行按邏輯或規則拆分成0行或多行輸出

示例環境

java.version: 1.8.x

flink.version: 1.11.1

示例數據源

FlatMap.java

import com.flink.demo.DataSource;

import org.apache.flink.api.common.functions.FlatMapFunction;

import org.apache.flink.api.common.functions.MapFunction;

import org.apache.flink.api.java.tuple.Tuple3;

import org.apache.flink.streaming.api.datastream.DataStream;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

import org.apache.flink.util.Collector;

import java.util.List;

public class FlatMap

/**

* 遍歷集合，打印數據流中每一條記錄中的所有字段

* @param args

* @throws Exception

*/

public static void main(String[] args) throws Exception {

final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

List> tuple3List = DataSource.getTuple3ToList();

DataStream dataStream = env.fromCollection(tuple3List).flatMap(new FlatMapFunction,String>() {

@Override

public void flatMap(Tuple3 tuple3, Collector out) throws Exception {

out.collect(tuple3.f0);

out.collect(tuple3.f1);

out.collect(tuple3.f2 + "");

}

});

dataStream.print();

env.execute("flink FlatMap job");

}

}

打印結果

4> 劉六

4> girl

4> 32

1> 張三

1> man

1> 20

1> 伍七

1> girl

1> 18

2> 李四

2> girl

2> 24

2> 吳八

2> man

2> 30

3> 王五

3> man

3> 29

示例項目(碼云下載)

# 稍后放出鏈接

總結

以上是生活随笔為你收集整理的java dataset flatmap_Flink 系例 之 FlatMap的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。