public interface FlowStepStrategy<Config>
The FlowStepStrategy interface allows for on the fly customization of
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 configuration values
before they are submitted to the underlying platform.
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.
void apply(Flow<Config> flow,
Copyright © 2007-2014 Concurrent, Inc. All Rights Reserved.