public abstract class AbstractCrystalizer extends Object implements Crystalizer
State for a given process ID is purged when a final completion event is received so there is no need for an explicit cache purge operation in the public API (although for termination of partially complete workflows it may be sensible for subclasses to provide one)
Modifier and Type | Class and Description |
---|---|
protected class |
AbstractCrystalizer.CompletionAwareTreeCache |
Constructor and Description |
---|
AbstractCrystalizer() |
Modifier and Type | Method and Description |
---|---|
abstract Job |
getEmptyJob(String owningProcess,
int[] index,
InvocationContext context) |
void |
receiveEvent(IterationInternalEvent<?> e)
Receive a Job or Completion, Jobs are emitted unaltered and cached,
Completion events trigger registration of a corresponding list - this may
be recursive in nature if the completion event's index implies nested
lists which have not been registered.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
completionCreated, jobCreated
public abstract Job getEmptyJob(String owningProcess, int[] index, InvocationContext context)
public void receiveEvent(IterationInternalEvent<?> e)
If the baseListDepth property is defined then completion events on nodes which don't already exist create empty jobs instead and emit those, if undefined the completion event is emited intact.
receiveEvent
in interface Crystalizer
e
- The event (a Job
or a Completion
)Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.