com.nicta.scoobi.io

sequence

package sequence

Visibility
  1. Public
  2. All

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 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.

Value Members

  1. object SeqSchema

  2. object SequenceInput extends SequenceInput

  3. object SequenceOutput extends SequenceOutput

Ungrouped