co.cask.cdap.etl.spark.streaming (Hydrator Spark1 Core Scala 2.10 4.3.3 API)