K
- The type of the input keysV
- The type of the input valuespublic class FileSplitRecordInfoLoader<K,V> extends InputSplitRecordInfoLoader<K,V>
RecordInfoLoader
. Returned RecordInfo
do not contain offset and length information.Constructor and Description |
---|
FileSplitRecordInfoLoader() |
Modifier and Type | Method and Description |
---|---|
static <K,V> java.lang.String |
getLocationField(RecordInfoProvider<K,V> riProvider, Configuration conf)
Gets the location field name which is the RecordInfo's field containing the the location text that can be sent to MVSuggest.
|
void |
startLoading(InputSplit split)
Sets the split to be read
|
finishLoading, getCurrReader, getKey, getLocationField, getRecordInfo, getRecordInfoProvider, getValue, hasNext, init, next, remove
public static <K,V> java.lang.String getLocationField(RecordInfoProvider<K,V> riProvider, Configuration conf)
riProvider
-conf
-public void startLoading(InputSplit split) throws java.io.IOException, java.lang.InterruptedException
RecordInfoLoader
startLoading
in interface RecordInfoLoader<K,V>
startLoading
in class InputSplitRecordInfoLoader<K,V>
split
- an input splitjava.io.IOException
java.lang.InterruptedException
Copyright © 2017, 2019 Oracle and/or its affiliates. All Rights Reserved.