K
- The type of the input keysV
- The type of the input values
public interface RecordInfoLoader<K,V>
RecordInfo
representation of records that are read from an input split, typically used in jobs where the whole block is passed to a mapper using FileSplitInputFormat
.RecordInfoProvider
defined in the in the job configuration.Modifier and Type | Method and Description |
---|---|
void |
finishLoading()
When called, stops reading the current split
|
<any> |
getCurrReader()
Gets the current reader
|
K |
getKey()
Gets the current record's key
|
java.lang.String |
getLocationField()
Gets the location field
|
RecordInfoProvider<K,V> |
getRecordInfoProvider()
Gets the current
RecordInfoProvider instance |
V |
getValue()
Gets the current record's value
|
void |
init(JobContext context)
Initializes the loader.
|
void |
startLoading(InputSplit split)
Sets the split to be read
|
void finishLoading() throws java.io.IOException
java.io.IOException
<any> getCurrReader()
K getKey()
java.lang.String getLocationField()
RecordInfoProvider<K,V> getRecordInfoProvider()
RecordInfoProvider
instanceV getValue()
void init(JobContext context)
context
- the job contextvoid startLoading(InputSplit split) throws java.io.IOException, java.lang.InterruptedException
split
- an input splitjava.io.IOException
java.lang.InterruptedException
Copyright © 2017 Oracle and/or its affiliates. All Rights Reserved.