Flink读数据

有界流

package com.atguigu.apiTest

import org.apache.flink.streaming.api.scala._


//传感器读数样例类
case class SensorReading(id:String, timestamp:Long, temperature: Double)

object SourceTest {
  def main(args: Array[String]): Unit = {

    val env: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment

    //1.从自定义的集合钟读取数据
    val stream1: DataStream[SensorReading] = env.fromCollection(List(
      SensorReading("sensor_1", 1547718199, 35.80018327300259),
      SensorReading("sensor_6", 1547718201, 15.402984393403084),
      SensorReading("sensor_7", 1547718202, 6.720945201171228),
      SensorReading("sensor_10", 1547718205, 38.101067604893444)

    ))

    //2.从文件中读取
    val stream2: DataStream[String] = env.readTextFile("C:\\Users\\Administrator\\Desktop\\0311Flink\\flink\\src\\main\\resources\\sensor")


    //3.从不同元素中读取
     env.fromElements(1,3, "aaa", 5.11).print()

    stream2.print("stream1:").setParallelism(1)

    env.execute()

  }

}