Oracle® In-Database Container for Hadoop Java API Reference
Release 1.0.1

E54638-01

oracle.hadoop.indbmr.lib.input
Class HInput<K,V>

java.lang.Object
  extended by 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)


Field Summary
protected  boolean CACHE_INPUT_FORMAT
           
protected  org.apache.hadoop.mapreduce.task.TaskAttemptContextImpl dummyTaskAttemptContextImpl
           
protected  org.apache.hadoop.mapreduce.InputFormat<K,V> inpFmt
           
protected  boolean SERDE_CONFIGURED
           
 
Constructor Summary
HInput()
           
 
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
 

Field Detail

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
Constructor Detail

HInput

public HInput()
Method Detail

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)

Oracle® In-Database Container for Hadoop Java API Reference
Release 1.0.1

E54638-01

Copyright © 2014, Oracle and/or its affiliates. All rights reserved.