September 2018
Intermediate to advanced
398 pages
9h 43m
English
Create the coinyser.BatchProducer class and type the following code:
package coinyserimport java.time.Instantimport java.util.concurrent.TimeUnitimport cats.Monadimport cats.effect.{IO, Timer}import cats.implicits._import org.apache.spark.sql.functions.{explode, from_json, lit}import org.apache.spark.sql.types._import org.apache.spark.sql.{Dataset, SaveMode, SparkSession}import scala.concurrent.duration._object BatchProducer { def jsonToHttpTransactions(json: String)(implicit spark: SparkSession): Dataset[HttpTransaction] = { import spark.implicits._ val ds: Dataset[String] = Seq(json).toDS() val txSchema: StructType = Seq.empty[HttpTransaction].schema val schema = ArrayType(txSchema) val arrayColumn = ...Read now
Unlock full access