source

Type Members

1. trait FunctionInput extends AnyRef

   Smart function for creating a distributed lists from a Scala function.

2. class FunctionInputFormat[A] extends InputFormat[NullWritable, A]

   InputFormat for producing values based on a function.

3. class FunctionInputSplit[A] extends InputSplit with Writable

   InputSplit for a range of values produced by a function.

4. class FunctionRecordReader[A] extends RecordReader[NullWritable, A]

   RecordReader for producing values based on a function.

5. class LazySeqInputFormat[A] extends InputFormat[NullWritable, A]

   InputFormat for producing values based on a lazy sequence.

6. trait SeqInput extends AnyRef

   Function for creating a distributed lists from a scala.

7. class SeqInputFormat[A] extends InputFormat[NullWritable, A]

   InputFormat for producing values based on a sequence.

8. class SeqInputSplit[A] extends InputSplit with Writable with Configured

   InputSplit for a range of values produced by a sequence.

9. class SeqRecordReader[A] extends RecordReader[NullWritable, A]

   RecordReader for producing sequences