Package | Description |
---|---|
com.marklogic.mapreduce |
MarkLogic Connector for Hadoop core
interfaces.
|
com.marklogic.mapreduce.examples |
Examples of using MarkLogic Server in MapReduce
jobs.
|
com.marklogic.mapreduce.test | |
com.marklogic.mapreduce.utilities |
Modifier and Type | Class and Description |
---|---|
class |
DocumentURIWithSourceInfo
Document URI with source information.
|
Modifier and Type | Method and Description |
---|---|
DocumentURI |
DocumentReader.getCurrentKey() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<DocumentURI,VALUEIN> |
DocumentInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
org.apache.hadoop.mapreduce.RecordWriter<DocumentURI,MarkLogicNode> |
PropertyOutputFormat.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
org.apache.hadoop.mapreduce.RecordWriter<DocumentURI,VALUEOUT> |
ContentOutputFormat.getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
int |
DocumentURI.compareTo(DocumentURI o) |
protected
com.marklogic.xcc.Content |
ContentWriter.createContent(DocumentURI key,
VALUEOUT value) |
void |
PropertyWriter.write(DocumentURI uri,
MarkLogicNode record) |
void |
ContentWriter.write(DocumentURI key,
VALUEOUT value) |
Constructor and Description |
---|
DocumentURI(DocumentURI uri) |
Modifier and Type | Method and Description |
---|---|
void |
BinaryReader.DocMapper.map(DocumentURI key,
org.apache.hadoop.io.BytesWritable value,
org.apache.hadoop.mapreduce.Mapper.Context context) |
void |
ContentReader.DocMapper.map(DocumentURI key,
DatabaseDocument value,
org.apache.hadoop.mapreduce.Mapper.Context context) |
void |
HelloWorld.MyMapper.map(DocumentURI key,
DatabaseDocument value,
org.apache.hadoop.mapreduce.Mapper.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
MapTreeReduceTreeJSON.MyMapper.map(DocumentURI key,
JSONDocument value,
org.apache.hadoop.mapreduce.Mapper.Context context) |
void |
MapTreeReduceTreeJSON.MyReducer.reduce(DocumentURI key,
Iterable<ForestDocument> docs,
org.apache.hadoop.mapreduce.Reducer.Context context) |
Modifier and Type | Method and Description |
---|---|
static String |
URIUtil.getPathFromURI(DocumentURI uri) |
int |
StatisticalAssignmentPolicy.getPlacementForestIndex(DocumentURI uri)
get the index of the forest with smallest number
of docs
|
int |
SegmentAssignmentPolicy.getPlacementForestIndex(DocumentURI uri) |
int |
LegacyAssignmentPolicy.getPlacementForestIndex(DocumentURI uri) |
int |
BucketAssignmentPolicy.getPlacementForestIndex(DocumentURI uri)
return the index to the list of updatable
forests (all forest - retired - RO/DO)
|
abstract int |
AssignmentPolicy.getPlacementForestIndex(DocumentURI uri) |
int |
AssignmentManager.getPlacementForestIndex(DocumentURI uri) |
static int |
SegmentAssignmentPolicy.getPlacementId(DocumentURI uri,
int size) |
static int |
LegacyAssignmentPolicy.getPlacementId(DocumentURI uri,
int size) |
static String |
InternalUtilities.getUriWithOutputDir(DocumentURI key,
String outputDir)
If outputDir is available and valid, modify
DocumentURI, and return uri in string
|
Copyright © 2020 MarkLogic
Corporation. All Rights Reserved.
Complete online documentation for MarkLogic Server,
XQuery and related components may be found at
developer.marklogic.com