public interface FlowStepStrategy<Config>
FlowStep
configuration values
before they are submitted to the underlying platform.
Use a strategy instance to change the display name for a job, or in the case of Hadoop, the number of mapper or reducer instances.
Note, to change the configuration information, FlowStep.getConfig()
must be
called to get access to the current configuration.
If any, the completed predecessor steps are provided so that the predecessors can be inspected via the
FlowStepStats
interface for any information that may influence the current job.
It is also possible to block submission of the job by blocking in this method.
Modifier and Type | Method and Description |
---|---|
void |
apply(Flow<Config> flow,
java.util.List<FlowStep<Config>> predecessorSteps,
FlowStep<Config> flowStep) |
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.