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