com.marklogic.mapreduce
Class PropertyWriter

java.lang.Object
  org.apache.hadoop.mapreduce.RecordWriter<KEYOUT,VALUEOUT>
      com.marklogic.mapreduce.MarkLogicRecordWriter<DocumentURI,MarkLogicNode>
          com.marklogic.mapreduce.PropertyWriter

All Implemented Interfaces:

MarkLogicConstants

public class PropertyWriter
extends MarkLogicRecordWriter<DocumentURI,MarkLogicNode>
implements MarkLogicConstants

MarkLogicRecordWriter that sets a property for a document.

Field Summary

static String	DOCURI_VARIABLE_NAME
static org.apache.commons.logging.Log	LOG
static String	NODE_VARIABLE_NAME

Fields inherited from class com.marklogic.mapreduce.MarkLogicRecordWriter

conf, hostName, txnSize

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

PropertyWriter(org.apache.hadoop.conf.Configuration conf, String host)

Method Summary

void	write(DocumentURI uri, MarkLogicNode record)

Methods inherited from class com.marklogic.mapreduce.MarkLogicRecordWriter

close, commitIfNecessary, getSession, getTransactionSize

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.apache.commons.logging.Log LOG

DOCURI_VARIABLE_NAME

public static final String DOCURI_VARIABLE_NAME

See Also:

Constant Field Values

NODE_VARIABLE_NAME

public static final String NODE_VARIABLE_NAME

See Also:

Constant Field Values

Constructor Detail

PropertyWriter

public PropertyWriter(org.apache.hadoop.conf.Configuration conf,
                      String host)

Method Detail

write

public void write(DocumentURI uri,
                  MarkLogicNode record)
           throws IOException,
                  InterruptedException

Specified by:

write in class org.apache.hadoop.mapreduce.RecordWriter<DocumentURI,MarkLogicNode>

Throws:

IOException

InterruptedException