public class MapReduceFlowStep extends HadoopFlowStep
flowStepStats, sinks, sources, tempSink
CASCADING_FLOW_STEP_ID
NULL
Modifier | Constructor and Description |
---|---|
protected |
MapReduceFlowStep(String flowName,
String stepName,
ElementGraph elementGraph,
FlowNodeGraph flowNodeGraph,
JobConf jobConf) |
protected |
MapReduceFlowStep(String flowName,
String stepName,
JobConf jobConf,
Tap sink) |
Modifier and Type | Method and Description |
---|---|
protected static FlowNodeGraph |
createFlowNodeGraph(JobConf jobConf) |
JobConf |
createInitializedConfig(FlowProcess<JobConf> flowProcess,
JobConf parentConfig) |
clean, cleanIntermediateData, createFlowStepJob, getConfigAsProperties, initFromSink, initFromSources, initFromTraps, isHadoopLocalMode
addAllGroups, addGroup, addGroups, addListener, addProcessAnnotation, addProcessAnnotation, addSink, addSinks, addSource, addSources, clean, commitSinks, configure, containsPipeNamed, createClientState, equals, fireOnCompleted, fireOnRunning, fireOnStarting, fireOnStopping, fireOnThrowable, getAllAccumulatedSources, getAllOperations, getAnnotations, getConfig, getCreateFlowStepJob, getElementGraph, getFlow, getFlowID, getFlowName, getFlowNodeGraph, getFlowStepDescriptor, 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, setFlowStepDescriptor, setFlowStepStats, setName, setOrdinal, setSubmitPriority, toString
protected MapReduceFlowStep(String flowName, String stepName, JobConf jobConf, Tap sink)
protected MapReduceFlowStep(String flowName, String stepName, ElementGraph elementGraph, FlowNodeGraph flowNodeGraph, JobConf jobConf)
public JobConf createInitializedConfig(FlowProcess<JobConf> flowProcess, JobConf parentConfig)
createInitializedConfig
in class HadoopFlowStep
protected static FlowNodeGraph createFlowNodeGraph(JobConf jobConf)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.