Interface for nodes within an iteration strategy layer
Stack of iteration strategy containers.
Abstract superclass for implementations of IterationStrategyNode, adds logic to connect nodes together and convenience methods to push jobs and completion events up to the parent node.
A superclass for all iteration strategy nodes which are required to propagate final completion events formed from multiple inputs.
A cross product node combines its inputs in an 'all against all' manner.
The dot product matches jobs by index array, when a job is received a job is emited if and only if the index array of the new job is matched exactly by index arrays of one job in each other input index.
Acts as the input to a stage within the iteration strategy, passes all jobs straight through.
Matches jobs where the index array of the job on index 0 is the prefix of the index array of the job on index 1.
The terminal node is the root of the iteration strategy tree, it is responsible for forwarding all events up to the iteration strategy itself which can then propogate them to the strategy stack.
Thrown during the typecheck phase when an iteration strategy is configured such that at runtime it would fail.
Thrown when an attempt is made to evaluate the type of the iteration strategy but one or more input ports aren't defined in the input array of types.
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.