public class MapReduceFlowStep extends HadoopFlowStep
flowStepStats, sinks, sources, tempSink
CASCADING_FLOW_STEP_ID
NULL
Modifier | Constructor and Description |
---|---|
protected |
MapReduceFlowStep(String flowName,
String stepName,
JobConf jobConf,
Tap sink) |
Modifier and Type | Method and Description |
---|---|
JobConf |
createInitializedConfig(FlowProcess<JobConf> flowProcess,
JobConf parentConfig) |
clean, createFlowStepJob, getConfigAsProperties, initFromSink, initFromSources, initFromTraps, isHadoopLocalMode
addGroup, addGroups, addListener, addProcessAnnotation, addProcessAnnotation, addSink, addSource, clean, commitSinks, configure, containsPipeNamed, createClientState, equals, fireOnCompleted, fireOnRunning, fireOnStarting, fireOnStopping, fireOnThrowable, getAllAccumulatedSources, getAllOperations, getAnnotations, getConfig, getCreateFlowStepJob, getElementGraph, getFlow, getFlowID, getFlowName, getFlowNodeGraph, getFlowStepJob, getFlowStepStats, getGroup, getGroups, getID, getName, getNextFlowElement, getNextScope, getNodeDisplayName, getNumFlowNodes, getOrdinal, getPreviousScopes, getProcessAnnotations, getSink, getSinkElements, getSinkName, getSinkTaps, getSinkWith, getSourceElements, getSourceName, getSourceTaps, getSourceWith, getStepDisplayName, getStepDisplayName, getSubmitPriority, getTrap, getTrapMap, getTraps, hashCode, hasListeners, initConfFromNodeConfigDef, initConfFromStepConfigDef, isDebugEnabled, isInfoEnabled, logDebug, logError, logError, logInfo, logWarn, logWarn, logWarn, prepareResources, removeListener, rollbackSinks, setConfig, setFlow, setFlowName, setFlowStepStats, setName, setOrdinal, setSubmitPriority, toString
protected MapReduceFlowStep(String flowName, String stepName, JobConf jobConf, Tap sink)
public JobConf createInitializedConfig(FlowProcess<JobConf> flowProcess, JobConf parentConfig)
createInitializedConfig
in class HadoopFlowStep
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.