V
- The type of the input valuespublic class KeyPosFileSplitRecordInfoLoader<V> extends FileSplitRecordInfoLoader<LongWritable,V>
RecordInfoLoader
that works with InputFormats which provide the records offsets in the records keys such as TextInputFormat
.RecordInfo
instances returned by this implementation will contain offset and and length information.Constructor and Description |
---|
KeyPosFileSplitRecordInfoLoader() |
Modifier and Type | Method and Description |
---|---|
boolean |
hasNext() |
RecordInfo |
next() |
void |
startLoading(InputSplit split)
Sets the split to be read
|
getLocationField
finishLoading, getCurrReader, getKey, getLocationField, getRecordInfo, getRecordInfoProvider, getValue, init, remove
public boolean hasNext()
hasNext
in class InputSplitRecordInfoLoader<LongWritable,V>
public RecordInfo next()
next
in class InputSplitRecordInfoLoader<LongWritable,V>
public void startLoading(InputSplit split) throws java.io.IOException, java.lang.InterruptedException
RecordInfoLoader
startLoading
in interface RecordInfoLoader<LongWritable,V>
startLoading
in class FileSplitRecordInfoLoader<LongWritable,V>
split
- an input splitjava.io.IOException
java.lang.InterruptedException
Copyright © 2017 Oracle and/or its affiliates. All Rights Reserved.