sequence

Type Members

1. class CheckedSeqSource[K, V, A] extends SeqSource[K, V, A]

   This class can check if the source types are ok, based on the Manifest of the input types

2. trait SeqSchema[A] extends AnyRef

   Type class for conversions between basic Scala types and Hadoop Writable types.

3. case class SeqSink[K, V, B](path: String, keyClass: Class[K], valueClass: Class[V], outputConverter: InputOutputConverter[K, V, B], overwrite: Boolean, check: (Path, Boolean, ScoobiConfiguration) ⇒ Unit = core.Sink.defaultOutputCheck, checkpoint: Option[Checkpoint] = scala.None, compression: Option[Compression] = scala.None) extends DataSink[K, V, B] with SinkSource with Product with Serializable

   class that abstracts all the common functionality of persisting to sequence files.

4. class SeqSource[K, V, A] extends DataSource[K, V, A]

5. trait SequenceInput extends AnyRef

   Smart functions for materialising distributed lists by loading Sequence files.

6. trait SequenceOutput extends AnyRef

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