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

   Function for creating a distributed lists from a scala.collection.Seq

   The code is very similar to the FunctionInput code but it was impossible to refactor due to the impossibility to parameterize InputFormat with values (only classes can be declared in a DataSource)

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