|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.solr.hadoop.morphline.MorphlineMapRunner
@Beta public final class MorphlineMapRunner
Internal helper for MorphlineMapper
and dryRun mode; This API is for *INTERNAL* use only
and should not be considered public.
Field Summary | |
---|---|
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 Summary | |
---|---|
MorphlineMapRunner(org.apache.hadoop.conf.Configuration configuration,
DocumentLoader loader,
String solrHomeDir)
|
Method Summary | |
---|---|
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. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
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
Constructor Detail |
---|
public MorphlineMapRunner(org.apache.hadoop.conf.Configuration configuration, DocumentLoader loader, String solrHomeDir) throws IOException
IOException
Method Detail |
---|
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()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |