public class FileInputFormatAdapter<K,V>
extends <any>
| Modifier and Type | Class and Description |
|---|---|
static class |
FileInputFormatAdapter.FileRecordReaderAdapter<K,V> |
static class |
FileInputFormatAdapter.FileSplitAdapter |
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
CONF_INPUT_FORMAT |
| Constructor and Description |
|---|
FileInputFormatAdapter() |
| Modifier and Type | Method and Description |
|---|---|
<any> |
createRecordReader(InputSplit split, TaskAttemptContext context) |
java.util.List<InputSplit> |
getSplits(JobContext context) |
static <K,V> void |
setInputFormatClass(java.lang.Class<? extends <any>> inputFormatClass, Configuration conf) |
public static final java.lang.String CONF_INPUT_FORMAT
public <any> createRecordReader(InputSplit split,
TaskAttemptContext context)
throws java.io.IOException,
java.lang.InterruptedException
java.io.IOExceptionjava.lang.InterruptedException
public java.util.List<InputSplit> getSplits(JobContext context)
throws java.io.IOException
java.io.IOException
public static <K,V> void setInputFormatClass(java.lang.Class<? extends <any>> inputFormatClass,
Configuration conf)
Copyright © 2017 Oracle and/or its affiliates. All Rights Reserved.