public class HadoopInputFormat<K,V> extends HadoopInputFormatBase<K,V,scala.Tuple2<K,V>>
fetched, hasNext, key, keyClass, value, valueClass
credentials
Constructor and Description |
---|
HadoopInputFormat(org.apache.hadoop.mapred.InputFormat<K,V> mapredInputFormat,
Class<K> keyClass,
Class<V> valueClass) |
HadoopInputFormat(org.apache.hadoop.mapred.InputFormat<K,V> mapredInputFormat,
Class<K> keyClass,
Class<V> valueClass,
org.apache.hadoop.mapred.JobConf job) |
Modifier and Type | Method and Description |
---|---|
scala.Tuple2<K,V> |
nextRecord(scala.Tuple2<K,V> reuse)
Reads the next record from the input.
|
close, configure, createInputSplits, fetchNext, getInputSplitAssigner, getJobConf, getStatistics, open, reachedEnd
getCredentialsFromUGI, read, write
closeInputFormat, getRuntimeContext, openInputFormat, setRuntimeContext
public HadoopInputFormat(org.apache.hadoop.mapred.InputFormat<K,V> mapredInputFormat, Class<K> keyClass, Class<V> valueClass, org.apache.hadoop.mapred.JobConf job)
public scala.Tuple2<K,V> nextRecord(scala.Tuple2<K,V> reuse)
InputFormat
When this method is called, the input format it guaranteed to be opened.
reuse
- Object that may be reused.Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.