oracle.hadoop.indbmr.lib.input
Class HInput<K,V>
java.lang.Object
oracle.hadoop.indbmr.lib.input.HInput<K,V>
public class HInput<K,V>
- extends java.lang.Object
Reads binary serialized splits from an InputStream
and
parses each split into rows
(key/value pairs) using the appropriate
InputFormat
This class assumes that it can get the name of the InputSplit from
the Configuration. INDBMR must put it there when it writes splits to
the VARBINARY table. See Javadoc for method getInputSplitClass(Configuration)
Method Summary |
protected java.lang.Class<? extends org.apache.hadoop.mapreduce.InputFormat> |
getInputFormatClass(org.apache.hadoop.conf.Configuration conf)
|
protected java.lang.Class<? extends org.apache.hadoop.mapreduce.InputSplit> |
getInputSplitClass(org.apache.hadoop.conf.Configuration conf)
|
void |
readSplits(org.apache.hadoop.conf.Configuration conf,
java.io.InputStream is)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
SERDE_CONFIGURED
protected boolean SERDE_CONFIGURED
inpFmt
protected org.apache.hadoop.mapreduce.InputFormat<K,V> inpFmt
CACHE_INPUT_FORMAT
protected boolean CACHE_INPUT_FORMAT
dummyTaskAttemptContextImpl
protected org.apache.hadoop.mapreduce.task.TaskAttemptContextImpl dummyTaskAttemptContextImpl
HInput
public HInput()
readSplits
public void readSplits(org.apache.hadoop.conf.Configuration conf,
java.io.InputStream is)
throws java.io.IOException,
java.lang.InterruptedException
- Throws:
java.io.IOException
java.lang.InterruptedException
getInputFormatClass
protected java.lang.Class<? extends org.apache.hadoop.mapreduce.InputFormat> getInputFormatClass(org.apache.hadoop.conf.Configuration conf)
getInputSplitClass
protected java.lang.Class<? extends org.apache.hadoop.mapreduce.InputSplit> getInputSplitClass(org.apache.hadoop.conf.Configuration conf)
Copyright © 2014, Oracle and/or its affiliates. All rights reserved.