ProxyRowLoader.scala

import org.apache.spark.sql._
import org.apache.spark.streaming.dstream.DStream

trait Loader[T] {
  def load(input: T)
}

class SuccessLoader(ctx: HiveContext) extends Loader[DStream[Row]] {
  override def load(stream: DStream[Row]) = {
    // Data aggregation and persistence
  }
}

class ErrorLoader(ctx: HiveContext) extends Loader[DStream[Row]] {
  // Uploads failed log entries
}