

package org.apache.spark.streaming.dstream

import scala.language.implicitConversions
import scala.reflect.ClassTag

import org.apache.spark.streaming._

/**
 * This is a class to provide access to zerotime information
 */
abstract class FriendlyInputDStream[T: ClassTag](
  @transient var ssc_ : StreamingContext)
    extends InputDStream[T](ssc_) {

  var ourZeroTime: Time = null

  override def initialize(time: Time) {
    ourZeroTime = time
    super.initialize(time)
  }
}
