com.marklogic.mapreduce
Class KeyValueInputFormat<KEYIN,VALUEIN>

java.lang.Object
  org.apache.hadoop.mapreduce.InputFormat<KEYIN,VALUEIN>
      com.marklogic.mapreduce.MarkLogicInputFormat<KEYIN,VALUEIN>
          com.marklogic.mapreduce.KeyValueInputFormat<KEYIN,VALUEIN>

Type Parameters:

KEYIN -

VALUEIN -

All Implemented Interfaces:

MarkLogicConstants

public class KeyValueInputFormat<KEYIN,VALUEIN>
extends MarkLogicInputFormat<KEYIN,VALUEIN>
implements MarkLogicConstants

MarkLogicInputFormat for user specified key and value types.

Your job may gather input data from a MarkLogic database and produce key-value pairs with type such as Text and IntWritable through implicit conversions performed by the connector. For details on the supported conversions, see "Using KeyValueInputFormat and ValueInputFormat" in the Hadoop MapReduce Connector Developer's Guide.

See Also:

LinkCount

Field Summary

Fields inherited from class com.marklogic.mapreduce.MarkLogicInputFormat

LOG

Fields inherited from interface com.marklogic.mapreduce.MarkLogicConstants

ADVANCED_MODE, BASIC_MODE, BATCH_SIZE, BIND_SPLIT_RANGE, CONTENT_TYPE, DEFAULT_BATCH_SIZE, DEFAULT_CONTENT_TYPE, DEFAULT_MAX_SPLIT_SIZE, DEFAULT_OUTPUT_CONTENT_ENCODING, DEFAULT_OUTPUT_XML_REPAIR_LEVEL, DEFAULT_PROPERTY_OPERATION_TYPE, DOCUMENT_SELECTOR, INDENTED, INPUT_DATABASE_NAME, INPUT_HOST, INPUT_KEY_CLASS, INPUT_LEXICON_FUNCTION_CLASS, INPUT_MODE, INPUT_PASSWORD, INPUT_PORT, INPUT_QUERY, INPUT_SSL_OPTIONS_CLASS, INPUT_USE_SSL, INPUT_USERNAME, INPUT_VALUE_CLASS, MAX_SPLIT_SIZE, MR_NAMESPACE, NODE_OPERATION_TYPE, OUTPUT_CLEAN_DIR, OUTPUT_COLLECTION, OUTPUT_CONTENT_ENCODING, OUTPUT_CONTENT_LANGUAGE, OUTPUT_CONTENT_NAMESPACE, OUTPUT_DIRECTORY, OUTPUT_FAST_LOAD, OUTPUT_FOREST_HOST, OUTPUT_HOST, OUTPUT_KEY_TYPE, OUTPUT_KEY_VARNAME, OUTPUT_NAMESPACE, OUTPUT_PASSWORD, OUTPUT_PERMISSION, OUTPUT_PORT, OUTPUT_PROPERTY_ALWAYS_CREATE, OUTPUT_QUALITY, OUTPUT_QUERY, OUTPUT_SSL_OPTIONS_CLASS, OUTPUT_STREAMING, OUTPUT_TOLERATE_ERRORS, OUTPUT_USE_SSL, OUTPUT_USERNAME, OUTPUT_VALUE_TYPE, OUTPUT_VALUE_VARNAME, OUTPUT_XML_REPAIR_LEVEL, PATH_NAMESPACE, PROPERTY_OPERATION_TYPE, RECORD_TO_FRAGMENT_RATIO, SPLIT_END_VARNAME, SPLIT_QUERY, SPLIT_START_VARNAME, SUBDOCUMENT_EXPRESSION, TXN_SIZE

Constructor Summary

KeyValueInputFormat()

Method Summary

org.apache.hadoop.mapreduce.RecordReader<KEYIN,VALUEIN>

createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)

Methods inherited from class com.marklogic.mapreduce.MarkLogicInputFormat

getSplits

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyValueInputFormat

public KeyValueInputFormat()

Method Detail

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<KEYIN,VALUEIN> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                  org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                           throws IOException,
                                                                                  InterruptedException

Specified by:

createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<KEYIN,VALUEIN>

Throws:

IOException

InterruptedException