public abstract class BaseCompositeInputFormat<K,V> extends java.lang.Object implements AbstractCompositeInputFormat<K,V>
Constructor and Description |
---|
BaseCompositeInputFormat() |
Modifier and Type | Method and Description |
---|---|
static <any> |
createInternalInputFormat(Configuration conf) |
static RecordInfoProvider<?,?> |
createRecordInfoProvider(java.lang.Class<? extends RecordInfoProvider<?,?>> recordInfoProviderClass, Configuration conf) |
<any> |
getInternalInputFormat(JobConf jobConf) |
static java.lang.Class<? extends <any>> |
getInternalInputFormatClass(Configuration conf) |
static RecordInfoProvider<?,?> |
getRecordInfoProvider(Configuration conf) |
static java.lang.Class<? extends RecordInfoProvider<?,?>> |
getRecordInfoProviderClass(Configuration conf) |
InputSplit[] |
getSplits(JobConf jobConf, int minSplits) |
static <K,V> void |
setInternalInputFormatClass(Configuration conf, java.lang.Class<? extends <any>> iInputFormat) |
static void |
setRecordInfoProviderClass(Configuration conf, java.lang.Class<? extends RecordInfoProvider<?,?>> provider) |
public static <any> createInternalInputFormat(Configuration conf)
public static RecordInfoProvider<?,?> createRecordInfoProvider(java.lang.Class<? extends RecordInfoProvider<?,?>> recordInfoProviderClass, Configuration conf)
public <any> getInternalInputFormat(JobConf jobConf)
getInternalInputFormat
in interface AbstractCompositeInputFormat<K,V>
public static java.lang.Class<? extends <any>> getInternalInputFormatClass(Configuration conf)
public static RecordInfoProvider<?,?> getRecordInfoProvider(Configuration conf)
public static java.lang.Class<? extends RecordInfoProvider<?,?>> getRecordInfoProviderClass(Configuration conf)
public InputSplit[] getSplits(JobConf jobConf, int minSplits) throws java.io.IOException
java.io.IOException
public static <K,V> void setInternalInputFormatClass(Configuration conf, java.lang.Class<? extends <any>> iInputFormat)
public static void setRecordInfoProviderClass(Configuration conf, java.lang.Class<? extends RecordInfoProvider<?,?>> provider)
Copyright © 2017 Oracle and/or its affiliates. All Rights Reserved.