Modifier and Type | Field and Description |
---|---|
InvocationContext |
DummyCallback.invocationContext |
Modifier and Type | Method and Description |
---|---|
InvocationContext |
DummyCallback.getContext() |
Modifier and Type | Method and Description |
---|---|
InvocationContext |
WorkflowInstanceFacade.getContext()
Return the invocation context used by this facade
|
Modifier and Type | Method and Description |
---|---|
InvocationContext |
WorkflowInstanceFacadeImpl.getContext() |
Constructor and Description |
---|
WorkflowInstanceFacadeImpl(Dataflow dataflow,
InvocationContext context,
String parentProcess) |
Modifier and Type | Field and Description |
---|---|
protected InvocationContext |
Event.context |
Modifier and Type | Method and Description |
---|---|
InvocationContext |
Event.getContext() |
Constructor and Description |
---|
Completion(String owningProcess,
int[] completionIndex,
InvocationContext context)
Construct a new optionally partial completion event with the specified
owner and completion index
|
Completion(String owningProcess,
InvocationContext context)
Construct a new final completion event, equivalent to calling new
Completion(owningProcess, new int[0]);
|
Event(String owner,
int[] index,
InvocationContext context) |
IterationInternalEvent(String owner,
int[] index,
InvocationContext context)
Protected constructor for the minimum fields required by all Event
subclasses
|
WorkflowDataToken(String owningProcess,
int[] index,
T2Reference dataRef,
InvocationContext context)
Construct a new data token with the specified owning process, conceptual
index array and data reference
|
Modifier and Type | Class and Description |
---|---|
class |
InvocationContextImpl |
Modifier and Type | Method and Description |
---|---|
void |
LocalExecutionMonitor.convertReferenceToPath(Path path,
T2Reference reference,
InvocationContext context) |
Modifier and Type | Method and Description |
---|---|
InvocationContext |
ProvenanceReporter.getInvocationContext()
Get the
InvocationContext that this reporter should be using if
it needs to dereference any data |
Modifier and Type | Method and Description |
---|---|
void |
ProvenanceReporter.setInvocationContext(InvocationContext invocationContext)
Set the
InvocationContext that this reporter should be using |
Modifier and Type | Method and Description |
---|---|
WorkflowInstanceFacade |
Edits.createWorkflowInstanceFacade(Dataflow dataflow,
InvocationContext context,
String parentProcess)
Build a new WorkflowInstanceFacade using the supplied Dataflow
|
void |
Processor.fire(String owningProcess,
InvocationContext context)
A processor with no inputs cannot be driven by the supply of data tokens
as it has nowhere to receive such tokens.
|
void |
Dataflow.fire(String owningProcess,
InvocationContext context)
A dataflow with no inputs cannot be driven by the supply of data tokens
as it has nowhere to receive such tokens.
|
Modifier and Type | Method and Description |
---|---|
WorkflowInstanceFacade |
EditsImpl.createWorkflowInstanceFacade(Dataflow dataflow,
InvocationContext context,
String parentProcess) |
void |
ProcessorImpl.fire(String enclosingProcess,
InvocationContext context) |
void |
DataflowImpl.fire(String owningProcess,
InvocationContext context) |
Job |
ProcessorCrystalizerImpl.getEmptyJob(String owningProcess,
int[] index,
InvocationContext context) |
abstract Job |
AbstractCrystalizer.getEmptyJob(String owningProcess,
int[] index,
InvocationContext context) |
protected abstract void |
AbstractFilteringInputPort.pushCompletion(String portName,
String owningProcess,
int[] index,
InvocationContext context)
Action to take when the filter pushes a completion event out
|
protected abstract void |
AbstractFilteringInputPort.pushData(String portName,
String owningProcess,
int[] index,
T2Reference data,
InvocationContext context)
Action to take when a data event is created by the filter
|
protected boolean |
DataflowImpl.tokenReceived(String owningProcess,
InvocationContext context)
Called when a token is received or the dataflow is fired, checks to see
whether the process identifier is already known (in which case we assume
it's been registered and can ignore it) or registers it with the monitor
along with all child entities.
|
Constructor and Description |
---|
CompletionAwareTreeCache(String owningProcess,
InvocationContext context) |
Modifier and Type | Method and Description |
---|---|
InvocationContext |
AsynchronousActivityCallback.getContext()
The invocation context contains resources such as data managers, security
agents and provenance consumers to be used by the Activity as it runs.
|
Constructor and Description |
---|
Job(String owner,
int[] index,
Map<String,T2Reference> data,
InvocationContext context)
Create a new Job object with the specified owning process (colon
separated 'list' of process identifiers), index array and data map
|
Constructor and Description |
---|
AbstractDispatchEvent(String owner,
int[] index,
InvocationContext context) |
DispatchCompletionEvent(String owner,
int[] index,
InvocationContext context)
Construct a new dispatch result completion event
|
DispatchErrorEvent(String owningProcess,
int[] index,
InvocationContext context,
String errorMessage,
Throwable t,
DispatchErrorType failureType,
Activity<?> failedActivity)
Create a new error event
|
DispatchJobEvent(String owningProcess,
int[] index,
InvocationContext context,
Map<String,T2Reference> data,
List<? extends Activity<?>> activities)
Create a new job event, specifying a complete set of input data and a
list of activities which could potentially consume this data
|
DispatchJobQueueEvent(String owner,
InvocationContext context,
BlockingQueue<IterationInternalEvent<? extends IterationInternalEvent<?>>> queue,
List<? extends Activity<?>> activities)
Create a new job queue event, specifying the queue of Completion and Job
objects and the list of activities which will be used to process the
corresponding dispatch events
|
DispatchResultEvent(String owner,
int[] index,
InvocationContext context,
Map<String,T2Reference> data,
boolean streaming)
Construct a new dispatch result event, specifying the data and whether
the result is part of a stream of multiple results events from a single
invocation
|
Modifier and Type | Method and Description |
---|---|
InvocationContext |
Loop.ConditionCallBack.getContext() |
InvocationContext |
Invoke.InvokeCallBack.getContext() |
Modifier and Type | Method and Description |
---|---|
void |
IterationStrategyStackImpl.receiveCompletion(String inputPortName,
String owningProcess,
int[] completionArray,
InvocationContext context) |
void |
IterationStrategyImpl.receiveCompletion(String inputPortName,
String owningProcess,
int[] completionArray,
InvocationContext context) |
void |
IterationStrategyStackImpl.receiveData(String inputPortName,
String owningProcess,
int[] indexArray,
T2Reference dataReference,
InvocationContext context) |
void |
IterationStrategyImpl.receiveData(String inputPortName,
String owningProcess,
int[] indexArray,
T2Reference dataReference,
InvocationContext context)
Receive a single data event from an upstream process.
|
Copyright © 2015–2016 The Apache Software Foundation. All rights reserved.