Interface | Description |
---|---|
FlatMapFunctionAdapter<T,R> |
A function that returns zero or more output records from each input record.
|
Class | Description |
---|---|
EmptyRecordFunction |
Used for filtering empty records
|
LineRecordReaderFunction |
LineRecordReaderFunction: Used to map a
JavaRDD<String> to a JavaRDD<Collection<Writable>>
Note that this is most useful with LineRecordReader instances (CSVRecordReader, SVMLightRecordReader, etc) |
RecordReaderFunction |
RecordReaderFunction: Given a RecordReader and a file (via Spark PortableDataStream), load and parse the
data into a Collection
|
SequenceRecordReaderFunction |
RecordReaderFunction: Given a SequenceRecordReader and a file (via Spark PortableDataStream), load and parse the
sequence data into a
List<List<Writable>> |
TestLineRecordReaderFunction |
Created by Alex on 21/05/2016.
|
TestPairSequenceRecordReaderBytesFunction | |
TestRecordReaderBytesFunction | |
TestRecordReaderFunction | |
TestSequenceRecordReaderBytesFunction | |
TestSequenceRecordReaderFunction |