使用列表数据作为Flink数据源进行控制台打印输出

1.maven依赖

  4.0.0

  com.github.lius
  flink
  0.0.1-SNAPSHOT
  jar

  flink
  http://maven.apache.org

  
    UTF-8
  

  
 	 
	  org.apache.flink
	  flink-java
	  1.9.2
	
	
	  org.apache.flink
	  flink-streaming-java_2.12
	  1.9.2
	
	
	  org.apache.flink
	  flink-connector-kafka-0.10_2.12
	  1.9.2
	
	
	  org.apache.flink
	  flink-clients_2.12
	  1.9.2
	 

	
    
      junit
      junit
      3.8.1
      test
    
  

2.Java代码

package com.github.lius.flink;

import java.util.ArrayList;
import java.util.List;

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

public class ListSource {
	public static void main(String[] args) throws Exception {
		// 创建stream环境
		StreamExecutionEnvironment streamEnv = StreamExecutionEnvironment.getExecutionEnvironment();
		// 创建列表数据
		List dataList = new ArrayList() {{add("1");add("2");add("3");add("4");}};
		// 将列表数据设置为source数据源
		DataStreamSource source = streamEnv.fromCollection(dataList);
		// 将source数据源进行控制台打印
		source.print();
		// 执行job
		streamEnv.execute("coll");
	}
}

3.控制台输出

SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
SLF4J: Defaulting to no-operation (NOP) logger implementation
SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
3> 3
2> 2
1> 1
4> 4