ProxyRowTransformer.scala

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

trait StreamTransformer[S, T] {
  def parse(input: DStream[S]): DStream[T]
}

class ProxyRowTransformer extends StreamTransformer[String, Row] {
  def parse(stream: DStream[String]): DStream[Row] = {   
    stream
    .transform(rdd => {
      rdd.map(line => {    
        // Transform lines of text into SQL records, include failures
      })
    })     
  }
}