package com.bigdata.flink.Flink_Sink
import java.util
import java.util._
import com.bigdata.flink.Tranform_Operator.SensorReading
import org.apache.flink.api.common.functions.RuntimeContext
import org.apache.flink.api.common.serialization.SimpleStringSchema
import org.apache.flink.api.scala._
import
1