com.marklogic.mapreduce
Class NodeReader

java.lang.Object
  org.apache.hadoop.mapreduce.RecordReader<KEYIN,VALUEIN>
      com.marklogic.mapreduce.MarkLogicRecordReader<NodePath,MarkLogicNode>
          com.marklogic.mapreduce.NodeReader

All Implemented Interfaces:

MarkLogicConstants, Closeable

public class NodeReader
extends MarkLogicRecordReader<NodePath,MarkLogicNode>

MarkLogicRecordReader for nodes where the key is NodePath.

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

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

Method Summary

protected void	endOfResult()
NodePath	getCurrentKey()
MarkLogicNode	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

NodeReader

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

Method Detail

getCurrentKey

public NodePath getCurrentKey()
                       throws IOException,
                              InterruptedException

Specified by:

getCurrentKey in class org.apache.hadoop.mapreduce.RecordReader<NodePath,MarkLogicNode>

Throws:

IOException

InterruptedException

endOfResult

protected void endOfResult()

Specified by:

endOfResult in class MarkLogicRecordReader<NodePath,MarkLogicNode>

nextResult

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

Specified by:

nextResult in class MarkLogicRecordReader<NodePath,MarkLogicNode>

getCurrentValue

public MarkLogicNode getCurrentValue()
                              throws IOException,
                                     InterruptedException

Specified by:

getCurrentValue in class org.apache.hadoop.mapreduce.RecordReader<NodePath,MarkLogicNode>

Throws:

IOException

InterruptedException

getDefaultRatio

protected float getDefaultRatio()

Specified by:

getDefaultRatio in class MarkLogicRecordReader<NodePath,MarkLogicNode>