org.apache.reef.io.data.loading.impl

Class InputFormatDataSet<K extends org.apache.hadoop.io.WritableComparable<K>,V extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.reef.io.data.loading.impl.InputFormatDataSet<K,V>

Type Parameters:

K -

V -

All Implemented Interfaces:

Iterable<Pair<K,V>>, DataSet<K,V>

public final class InputFormatDataSet<K extends org.apache.hadoop.io.WritableComparable<K>,V extends org.apache.hadoop.io.Writable>
extends Object
implements DataSet<K,V>

An implementation of DataSet that reads records using a RecordReader encoded inside an InputSplit.

The input split is injected through an external constructor by deserializing the input split assigned to this evaluator.

Constructor Summary

Constructors

Constructor and Description
InputFormatDataSet(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf jobConf)

Method Summary

Methods

Modifier and Type	Method and Description
Iterator<Pair<K,V>>	iterator()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

InputFormatDataSet

@Inject
public InputFormatDataSet(org.apache.hadoop.mapred.InputSplit split,
                         org.apache.hadoop.mapred.JobConf jobConf)

Method Detail

iterator

public Iterator<Pair<K,V>> iterator()

Specified by:

iterator in interface Iterable<Pair<K extends org.apache.hadoop.io.WritableComparable<K>,V extends org.apache.hadoop.io.Writable>>