Flink常用API之Collection的Source

package source

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

/**
 * @Author yqq
 * @Date 2021/12/25 14:58
 * @Version 1.0
 */
case class StationLog(sid:String,callOut:String,callInput:String,callType:String,callTime:Long,duration:Long)
object CollectionSource {
  def main(args: Array[String]): Unit = {
    val ev: StreamExecutionEnvironment = StreamExecutionEnvironment.getExecutionEnvironment
    ev.setParallelism(1)
    import org.apache.flink.streaming.api.scala._
    val list: DataStream[StationLog] = ev.fromCollection(Array(
      new StationLog("1001", "10086", "181", "busy", 15551, 0),
      new StationLog("1002", "10087", "182", "busy", 15552, 0),
      new StationLog("1003", "10088", "183", "success", 13555, 30),
      new StationLog("1004", "10089", "184", "success", 15545, 20),
      new StationLog("1005", "10080", "185", "busy", 15565, 0)

    ))
    list.print()
    ev.execute("array")
  }
}