public class IterationStrategyStackImpl extends Object implements IterationStrategyStack
Constructor and Description |
---|
IterationStrategyStackImpl() |
Modifier and Type | Method and Description |
---|---|
void |
addStrategy(IterationStrategy is) |
void |
clear() |
int |
getIterationDepth(Map<String,Integer> inputDepths)
The iteration depth here is calculated by taking first the top iteration
strategy and applying the actual input types to it, then for each
subsequent strategy in the stack using the 'desired cardinality' of the
input nodes for each layer to work out the increase in index array
length.
|
List<IterationStrategyImpl> |
getStrategies()
The iteration strategy stack consists of an ordered list of iteration
strategies.
|
protected IterationStrategyImpl |
layerBelow(IterationStrategyImpl that)
Return the layer below the specified one, or null if there is no lower
layer
|
void |
receiveCompletion(String inputPortName,
String owningProcess,
int[] completionArray,
InvocationContext context) |
void |
receiveData(String inputPortName,
String owningProcess,
int[] indexArray,
T2Reference dataReference,
InvocationContext context) |
protected void |
receiveEventFromStrategy(IterationInternalEvent<? extends IterationInternalEvent<?>> e)
Called by the final iteration strategy to push events onto the
dispatcher's queue
|
void |
removeStrategy(IterationStrategy is) |
public int getIterationDepth(Map<String,Integer> inputDepths) throws IterationTypeMismatchException, MissingIterationInputException
getIterationDepth
in interface IterationStrategyStack
inputDepths
- IterationTypeMismatchException
MissingIterationInputException
public void addStrategy(IterationStrategy is)
public void removeStrategy(IterationStrategy is)
public List<IterationStrategyImpl> getStrategies()
IterationStrategyStack
getStrategies
in interface IterationStrategyStack
public void clear()
public void receiveData(String inputPortName, String owningProcess, int[] indexArray, T2Reference dataReference, InvocationContext context)
public void receiveCompletion(String inputPortName, String owningProcess, int[] completionArray, InvocationContext context)
protected IterationStrategyImpl layerBelow(IterationStrategyImpl that)
protected void receiveEventFromStrategy(IterationInternalEvent<? extends IterationInternalEvent<?>> e)
e
- Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.