oracle.kv.hadoop
Class KVAvroInputFormat

java.lang.Object
  org.apache.hadoop.mapreduce.InputFormat<K,V>
      oracle.kv.hadoop.KVInputFormatBase<Key,IndexedRecord>
          oracle.kv.hadoop.KVAvroInputFormat

public class KVAvroInputFormat
extends KVInputFormatBase<Key,IndexedRecord>

A Hadoop InputFormat class for reading data from Oracle NoSQL Database and returning Avro IndexedRecords as the map-reduce value and the record's Key as the map-reduce key.

One use for this class is to read NoSQL Database records into Oracle Loader for Hadoop.

Refer to the javadoc for KVInputFormatBase for information on the parameters that may be passed to this class.

Since:

2.0

Constructor Summary

KVAvroInputFormat()

Method Summary

Methods inherited from class oracle.kv.hadoop.KVInputFormatBase

setBatchSize, setConsistency, setDepth, setDirection, setFormatterClassName, setKVHelperHosts, setKVStoreName, setParentKey, setSubRange, setTimeout, setTimeoutUnit

Methods inherited from class org.apache.hadoop.mapreduce.InputFormat

createRecordReader, getSplits

Methods inherited from class java.lang.Object

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

Constructor Detail

KVAvroInputFormat

public KVAvroInputFormat()