text

Type Members

1. case class TextFileSink[A](path: String, overwrite: Boolean = false, check: (Path, Boolean, ScoobiConfiguration) ⇒ Unit = core.Sink.defaultOutputCheck, compression: Option[Compression] = scala.None)(implicit evidence$5: Manifest[A]) extends DataSink[NullWritable, A, A] with Product with Serializable

2. trait TextInput extends AnyRef

   Smart functions for materialising distributed lists by loading text files.

3. trait TextOutput extends AnyRef

   Smart functions for persisting distributed lists by storing them as text files.

4. case class TextSource[A](paths: Seq[String], inputFormat: Class[_ <: FileInputFormat[LongWritable, Text]] = ..., inputConverter: InputConverter[LongWritable, Text, A] = TextInput.defaultTextConverter, check: (Seq[Path], ScoobiConfiguration) ⇒ Unit = core.Source.defaultInputCheck)(implicit evidence$3: WireFormat[A]) extends DataSource[LongWritable, Text, A] with Product with Serializable

   Class that abstracts all the common functionality of reading from text files.