public class FileSplitRecordInfoLoader<K,V> extends RecordInfoLoader<K,V>
Constructor and Description |
---|
FileSplitRecordInfoLoader(JobConf conf)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
RecordInfo |
next() |
void |
startLoading(InputSplit split, Reporter reporter)
Prepares the loader to start reading records from the given split
|
finishLoading, getCurrReader, getKey, getLocationField, getLocationField, getRecordInfoProvider, getValue, hasNext, remove
public FileSplitRecordInfoLoader(JobConf conf)
CompositeInputFormat
and RecordInfoProvider
conf
- the job configurationpublic RecordInfo next()
next
in class RecordInfoLoader<K,V>
public void startLoading(InputSplit split, Reporter reporter) throws java.io.IOException
startLoading
in class RecordInfoLoader<K,V>
split
- the split where the data will be read fromreporter
- a reporter instancejava.io.IOException
Copyright © 2017, 2019 Oracle and/or its affiliates. All Rights Reserved.