oracle.spatial.hadoop.vector.nosql.mapred

Class NoSQLInputFormat

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,RecordInfo>

oracle.spatial.hadoop.vector.nosql.mapreduce.NoSQLInputFormat

oracle.spatial.hadoop.vector.nosql.mapred.NoSQLInputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,RecordInfo>

public class NoSQLInputFormat
extends NoSQLInputFormat
implements org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,RecordInfo>

A version of NoSQLInputFormat for the Hadoop old API

Constructor Summary

Constructors

Constructor and Description
NoSQLInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,RecordInfo>	getRecordReader(org.apache.hadoop.mapred.InputSplit split, org.apache.hadoop.mapred.JobConf jobConf, org.apache.hadoop.mapred.Reporter reporter)
org.apache.hadoop.mapred.InputSplit[]	getSplits(org.apache.hadoop.mapred.JobConf jobConf, int minSplits)

Methods inherited from class oracle.spatial.hadoop.vector.nosql.mapreduce.NoSQLInputFormat

createRecordReader, getKVConfiguration, getSplits, getSplits

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NoSQLInputFormat

public NoSQLInputFormat()

Method Detail

getRecordReader

public org.apache.hadoop.mapred.RecordReader<org.apache.hadoop.io.Text,RecordInfo> getRecordReader(org.apache.hadoop.mapred.InputSplit split,
                                                                                                   org.apache.hadoop.mapred.JobConf jobConf,
                                                                                                   org.apache.hadoop.mapred.Reporter reporter)
                                                                                            throws java.io.IOException

Specified by:

getRecordReader in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,RecordInfo>

Throws:

java.io.IOException

getSplits

public org.apache.hadoop.mapred.InputSplit[] getSplits(org.apache.hadoop.mapred.JobConf jobConf,
                                                       int minSplits)
                                                throws java.io.IOException

Specified by:

getSplits in interface org.apache.hadoop.mapred.InputFormat<org.apache.hadoop.io.Text,RecordInfo>

Throws:

java.io.IOException