com.marklogic.mapreduce
Class DocumentReader<VALUEIN>

java.lang.Object
  org.apache.hadoop.mapreduce.RecordReader<KEYIN,VALUEIN>
      com.marklogic.mapreduce.MarkLogicRecordReader<DocumentURI,VALUEIN>
          com.marklogic.mapreduce.DocumentReader<VALUEIN>

All Implemented Interfaces:

MarkLogicConstants, Closeable

public class DocumentReader<VALUEIN>
extends MarkLogicRecordReader<DocumentURI,VALUEIN>

MarkLogicRecordReader for documents where the key is DocumentURI.

Field Summary

Fields inherited from class com.marklogic.mapreduce.MarkLogicRecordReader

conf, count, length, LOG, mlSplit, result, session

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

DocumentReader(org.apache.hadoop.conf.Configuration conf)

Method Summary

protected void	endOfResult()
DocumentURI	getCurrentKey()
VALUEIN	getCurrentValue()
protected float	getDefaultRatio()
protected boolean	nextResult(com.marklogic.xcc.ResultItem result)

Methods inherited from class com.marklogic.mapreduce.MarkLogicRecordReader

close, getConf, getCount, getProgress, initialize, nextKeyValue

Methods inherited from class java.lang.Object

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

Constructor Detail

DocumentReader

public DocumentReader(org.apache.hadoop.conf.Configuration conf)

Method Detail

getCurrentKey

public DocumentURI getCurrentKey()
                          throws IOException,
                                 InterruptedException

Specified by:

getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<DocumentURI,VALUEIN>

Throws:

IOException

InterruptedException

endOfResult

protected void endOfResult()

Specified by:

endOfResult in class MarkLogicRecordReader<DocumentURI,VALUEIN>

nextResult

protected boolean nextResult(com.marklogic.xcc.ResultItem result)

Specified by:

nextResult in class MarkLogicRecordReader<DocumentURI,VALUEIN>

getCurrentValue

public VALUEIN getCurrentValue()
                        throws IOException,
                               InterruptedException

Specified by:

getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<DocumentURI,VALUEIN>

Throws:

IOException

InterruptedException

getDefaultRatio

protected float getDefaultRatio()

Specified by:

getDefaultRatio in class MarkLogicRecordReader<DocumentURI,VALUEIN>