DeviceMeasurement_V1.scala

sealed trait DeviceMeasurement

object DeviceMeasurement {
  implicit val deviceMeasurementDataSource = new DataSource[DeviceMeasurement, Unit] {
    override def read(parameters: Unit)(implicit spark: SparkSession) =
      AnnotatedDataFrame[DeviceMeasurement](
        spark.createDataFrame(Seq(
          (0, 1.0),
          (0, 2.0),
          (1, 3.0)
        ))
        .toDF("device_model_id", "measurement_value")
      )
  }
}