PartitionSource

abstract def basePath: String

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

final def asInstanceOf[T0]: T0

def checkFlowDefNotNull()(implicit flowDef: FlowDef, mode: Mode): Unit

def clone(): AnyRef

def createHfsTap(scheme: Scheme[JobConf, RecordReader[_, _], OutputCollector[_, _], _, _], path: String, sinkMode: SinkMode): Hfs

def createTap(readOrWrite: AccessMode)(implicit mode: Mode): Tap[_, _, _]

Creates the partition tap.

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

def hdfsScheme: Scheme[JobConf, RecordReader[_, _], OutputCollector[_, _], _, _]

The scheme to use if the source is on hdfs.

final def isInstanceOf[T0]: Boolean

def localScheme: Scheme[Properties, InputStream, OutputStream, _, _]

The scheme to use if the source is local.

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

val openWritesThreshold: Option[Int]

def partition: Partition

def read(implicit flowDef: FlowDef, mode: Mode): Pipe

val sinkMode: SinkMode

def sourceId: String

This is a name the refers to this exact instance of the source (put another way, if s1.sourceId == s2.sourceId, the job should work the same if one is replaced with the other

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

def transformForRead(pipe: Pipe): Pipe

def transformForWrite(pipe: Pipe): Pipe

def transformInTest: Boolean

The mock passed in to scalding.JobTest may be considered as a mock of the Tap or the Source.

def validateTaps(mode: Mode): Unit

Validates the taps, makes sure there are no nulls in the path.

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def writeFrom(pipe: Pipe)(implicit flowDef: FlowDef, mode: Mode): Pipe

write the pipe but return the input so it can be chained into the next operation

def readAtSubmitter[T](implicit mode: Mode, conv: TupleConverter[T]): Stream[T]