@Beta public final class MorphlineMapRunner extends Object
MorphlineMapper
and dryRun mode; This API is for *INTERNAL* use only
and should not be considered public.Modifier and Type | Field and Description |
---|---|
static String |
DISABLE_FILE_OPEN
Flag to disable reading of file contents if indexing just file metadata is sufficient.
|
static String |
MORPHLINE_FIELD_PREFIX
Headers, including MIME types, can also explicitly be passed by force from the CLI to Morphline, e.g:
hadoop ...
|
static String |
MORPHLINE_FILE_PARAM |
static String |
MORPHLINE_ID_PARAM |
static String |
MORPHLINE_VARIABLE_PARAM
Morphline variables can be passed from the CLI to the Morphline, e.g.:
hadoop ...
|
Constructor and Description |
---|
MorphlineMapRunner(org.apache.hadoop.conf.Configuration configuration,
DocumentLoader loader,
String solrHomeDir) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
protected org.kitesdk.morphline.api.Record |
getRecord(PathParts parts) |
void |
map(String value,
org.apache.hadoop.conf.Configuration configuration,
org.apache.hadoop.mapreduce.Mapper.Context context)
Extract content from the path specified in the value.
|
public static final String MORPHLINE_FILE_PARAM
public static final String MORPHLINE_ID_PARAM
public static final String MORPHLINE_VARIABLE_PARAM
public static final String MORPHLINE_FIELD_PREFIX
public static final String DISABLE_FILE_OPEN
public MorphlineMapRunner(org.apache.hadoop.conf.Configuration configuration, DocumentLoader loader, String solrHomeDir) throws IOException
IOException
public void map(String value, org.apache.hadoop.conf.Configuration configuration, org.apache.hadoop.mapreduce.Mapper.Context context) throws IOException
IOException
protected org.kitesdk.morphline.api.Record getRecord(PathParts parts)
public void cleanup()
Copyright © 2000-2016 Apache Software Foundation. All Rights Reserved.