Modifier and Type | Method and Description |
---|---|
void |
DataflowActivity.executeAsynch(Map<String,T2Reference> data,
AsynchronousActivityCallback callback) |
Modifier and Type | Method and Description |
---|---|
void |
StringConstantActivity.executeAsynch(Map<String,T2Reference> data,
AsynchronousActivityCallback callback) |
Modifier and Type | Field and Description |
---|---|
Map<String,T2Reference> |
DummyCallback.data |
Modifier and Type | Method and Description |
---|---|
void |
DummyCallback.receiveResult(Map<String,T2Reference> data,
int[] index) |
Modifier and Type | Method and Description |
---|---|
WeakHashMap<String,T2Reference> |
WorkflowInstanceFacade.getPushedDataMap()
Return a map of the data pushed on the named port
|
Modifier and Type | Method and Description |
---|---|
WeakHashMap<String,T2Reference> |
WorkflowInstanceFacadeImpl.getPushedDataMap() |
Modifier and Type | Method and Description |
---|---|
T2Reference |
WorkflowDataToken.getData()
Return the ID of the data this event represents
|
Constructor and Description |
---|
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 | Method and Description |
---|---|
void |
LocalExecutionMonitor.convertReferenceToPath(Path path,
T2Reference reference,
InvocationContext context) |
Modifier and Type | Method and Description |
---|---|
T2Reference |
WorkflowDataProvenanceItem.getData() |
Modifier and Type | Method and Description |
---|---|
Map<String,T2Reference> |
DataProvenanceItem.getDataMap() |
Modifier and Type | Method and Description |
---|---|
void |
WorkflowDataProvenanceItem.setData(T2Reference data) |
Modifier and Type | Method and Description |
---|---|
void |
DataProvenanceItem.setDataMap(Map<String,T2Reference> dataMap) |
Modifier and Type | Method and Description |
---|---|
T2Reference |
ErrorDocumentService.getChild(T2Reference errorId)
Return the T2Reference for the sole child of an error document
identifier.
|
T2Reference |
Identified.getId()
Return an appropriately configured instance of T2Reference for this
identified object.
|
T2Reference |
ContextualizedT2Reference.getReference() |
T2Reference |
T2ReferenceGenerator.nextErrorDocumentReference(int depth,
ReferenceContext context)
Create a new and otherwise unused T2Reference to an ErrorDocument.
|
T2Reference |
T2ReferenceGenerator.nextListReference(boolean containsErrors,
int listDepth,
ReferenceContext context)
Create a new and otherwise unused T2Reference to an IdentifiedList.
|
T2Reference |
T2ReferenceGenerator.nextReferenceSetReference(ReferenceContext context)
Create a new and otherwise unused T2Reference to a ReferenceSet.
|
T2Reference |
ReferenceService.referenceFromString(String reference)
Given a string representation of a T2Reference create a new T2Reference
with the correct depth etc.
|
T2Reference |
ReferenceService.register(Object o,
int targetDepth,
boolean useConverterSPI,
ReferenceContext context)
The top level registration method is used to register either as yet
unregistered ErrorDocuments and ReferenceSets (if these are passed in and
already have an identifier this call does nothing) and arbitrarily nested
Lists of the same.
|
Modifier and Type | Method and Description |
---|---|
IdentifiedList<T2Reference> |
ListDao.get(T2Reference reference)
Retrieves a named and populated IdentifiedList of T2Reference from the
database by T2Reference
|
Set<T2Reference> |
ErrorDocument.getErrorReferences()
If the error document is created from set of references that contain
error documents, this method returns them.
|
IdentifiedList<T2Reference> |
ListService.getList(T2Reference id)
Retrieve a previously named and registered list of T2Reference instances
identified by the specified T2Reference (which must be of type
T2ReferenceType.IdentifiedList)
|
IdentifiedList<T2Reference> |
ListService.registerEmptyList(int depth,
ReferenceContext context)
Register a new empty list with the specified depth.
|
IdentifiedList<T2Reference> |
ListService.registerList(List<T2Reference> items,
ReferenceContext context)
Register a new list of T2References.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ReferenceSetService.delete(T2Reference reference) |
boolean |
ReferenceService.delete(T2Reference reference) |
boolean |
ListService.delete(T2Reference reference) |
boolean |
ErrorDocumentService.delete(T2Reference reference) |
ReferenceSet |
ReferenceSetDao.get(T2Reference ref)
Fetch a reference set by id
|
Identified |
ReferenceServiceCacheProvider.get(T2Reference id)
Called before an attempt is made to retrieve an item from the backing
store
|
IdentifiedList<T2Reference> |
ListDao.get(T2Reference reference)
Retrieves a named and populated IdentifiedList of T2Reference from the
database by T2Reference
|
ErrorDocument |
ErrorDocumentDao.get(T2Reference reference)
Retrieves a named and populated ErrorDocument
|
T2Reference |
ErrorDocumentService.getChild(T2Reference errorId)
Return the T2Reference for the sole child of an error document
identifier.
|
ErrorDocument |
ErrorDocumentService.getError(T2Reference id)
Retrieve a previously named and registered ErrorDocument from the backing
store
|
void |
ErrorDocumentService.getErrorAsynch(T2Reference id,
ErrorDocumentServiceCallback callback)
Functionality the same as
getError but in
asynchronous mode, returning immediately and using the supplied callback
to communicate its results. |
IdentifiedList<T2Reference> |
ListService.getList(T2Reference id)
Retrieve a previously named and registered list of T2Reference instances
identified by the specified T2Reference (which must be of type
T2ReferenceType.IdentifiedList)
|
void |
ListService.getListAsynch(T2Reference id,
ListServiceCallback callback)
Functionality the same as
getList but in
asynchronous mode, returning immediately and using the supplied callback
to communicate its results. |
ReferenceSet |
ReferenceSetService.getReferenceSet(T2Reference id)
Get a previously registered
ReferenceSet by T2Reference . |
void |
ReferenceSetService.getReferenceSetAsynch(T2Reference id,
ReferenceSetServiceCallback callback)
Functionality the same as
getReferenceSet but in asynchronous mode, returning immediately and
using the supplied callback to communicate its results. |
ReferenceSet |
ReferenceSetService.getReferenceSetWithAugmentation(T2Reference id,
Set<Class<ExternalReferenceSPI>> ensureTypes,
ReferenceContext context)
Functionality the same as
getReferenceSet but with the additional option to specify a set of
ExternalReferenceSPI classes. |
void |
ReferenceSetService.getReferenceSetWithAugmentationAsynch(T2Reference id,
Set<Class<ExternalReferenceSPI>> ensureTypes,
ReferenceContext context,
ReferenceSetServiceCallback callback)
Functionality as
getReferenceSetWithAugmentation but with the addition of a callback
interface to report the result or failure of the method. |
Object |
ReferenceService.renderIdentifier(T2Reference id,
Class<?> leafClass,
ReferenceContext context)
Resolve the given identifier, building a POJO structure where the
non-list items are of the desired class.
|
Identified |
ReferenceService.resolveIdentifier(T2Reference id,
Set<Class<ExternalReferenceSPI>> ensureTypes,
ReferenceContext context)
Perform recursive identifier resolution, building a collection structure
of Identified objects, any collection elements being IdentifiedLists of
Identified subclasses.
|
void |
ReferenceService.resolveIdentifierAsynch(T2Reference id,
Set<Class<ExternalReferenceSPI>> ensureTypes,
ReferenceContext context,
ReferenceServiceResolutionCallback callback)
As resolveIdentifier but using a callback object and returning
immediately
|
Iterator<ContextualizedT2Reference> |
ReferenceService.traverseFrom(T2Reference source,
int desiredDepth)
Initiates a traversal of the specified t2reference, traversing to
whatever level of depth is required such that all identifiers returned
within the iterator have the specified depth.
|
Modifier and Type | Method and Description |
---|---|
boolean |
ListDao.delete(IdentifiedList<T2Reference> theList) |
boolean |
ReferenceService.delete(List<T2Reference> references) |
void |
ListServiceCallback.listRetrieved(IdentifiedList<T2Reference> references)
Called when the requested
ReferenceSet has been successfully
retrieved. |
ErrorDocument |
ErrorDocumentService.registerError(String message,
Set<T2Reference> errors,
int depth,
ReferenceContext context)
Register a new error document.
|
IdentifiedList<T2Reference> |
ListService.registerList(List<T2Reference> items,
ReferenceContext context)
Register a new list of T2References.
|
void |
ListDao.store(IdentifiedList<T2Reference> theList)
Store a named and populated IdentifiedList of T2Reference to the
database.
|
Modifier and Type | Class and Description |
---|---|
class |
T2ReferenceImpl
An implementation of T2Reference specific to the ReferenceSetImpl.
|
Modifier and Type | Method and Description |
---|---|
T2Reference |
ErrorDocumentServiceImpl.getChild(T2Reference errorId) |
T2Reference |
AbstractEntityImpl.getId() |
T2Reference |
ContextualizedT2ReferenceImpl.getReference() |
T2Reference |
AbstractT2ReferenceGenerator.nextErrorDocumentReference(int depth,
ReferenceContext context) |
T2Reference |
AbstractT2ReferenceGenerator.nextListReference(boolean containsErrors,
int listDepth,
ReferenceContext context) |
T2Reference |
AbstractT2ReferenceGenerator.nextReferenceSetReference(ReferenceContext context) |
T2Reference |
ReferenceServiceImpl.referenceFromString(String reference)
Parse the reference contained in the string and return a
T2Reference with the correct properties |
T2Reference |
ReferenceServiceImpl.register(Object o,
int targetDepth,
boolean useConverterSPI,
ReferenceContext context)
The top level registration method is used to register either as yet
unregistered ErrorDocuments and ReferenceSets (if these are passed in and
already have an identifier this call does nothing) and arbitrarily nested
Lists of the same.
|
Modifier and Type | Method and Description |
---|---|
IdentifiedList<T2Reference> |
InMemoryListDao.get(T2Reference reference) |
Set<T2Reference> |
ErrorDocumentImpl.getErrorReferences() |
IdentifiedList<T2Reference> |
ListServiceImpl.getList(T2Reference id) |
IdentifiedList<T2Reference> |
ListServiceImpl.registerEmptyList(int depth,
ReferenceContext context) |
IdentifiedList<T2Reference> |
ListServiceImpl.registerList(List<T2Reference> items,
ReferenceContext context) |
Modifier and Type | Method and Description |
---|---|
boolean |
ReferenceSetServiceImpl.delete(T2Reference reference) |
boolean |
ReferenceServiceImpl.delete(T2Reference reference) |
boolean |
ListServiceImpl.delete(T2Reference reference) |
boolean |
ErrorDocumentServiceImpl.delete(T2Reference reference) |
Identified |
SimpleCacheProviderImpl.get(T2Reference id) |
ReferenceSet |
InMemoryReferenceSetDao.get(T2Reference reference) |
IdentifiedList<T2Reference> |
InMemoryListDao.get(T2Reference reference) |
ErrorDocument |
InMemoryErrorDocumentDao.get(T2Reference reference) |
static T2ReferenceImpl |
T2ReferenceImpl.getAsImpl(T2Reference source) |
T2Reference |
ErrorDocumentServiceImpl.getChild(T2Reference errorId) |
ErrorDocument |
ErrorDocumentServiceImpl.getError(T2Reference id) |
void |
AbstractErrorDocumentServiceImpl.getErrorAsynch(T2Reference id,
ErrorDocumentServiceCallback callback) |
IdentifiedList<T2Reference> |
ListServiceImpl.getList(T2Reference id) |
void |
AbstractListServiceImpl.getListAsynch(T2Reference id,
ListServiceCallback callback) |
ReferenceSet |
ReferenceSetServiceImpl.getReferenceSet(T2Reference id) |
void |
AbstractReferenceSetServiceImpl.getReferenceSetAsynch(T2Reference id,
ReferenceSetServiceCallback callback) |
ReferenceSet |
ReferenceSetServiceImpl.getReferenceSetWithAugmentation(T2Reference id,
Set<Class<ExternalReferenceSPI>> ensureTypes,
ReferenceContext context) |
void |
AbstractReferenceSetServiceImpl.getReferenceSetWithAugmentationAsynch(T2Reference id,
Set<Class<ExternalReferenceSPI>> ensureTypes,
ReferenceContext context,
ReferenceSetServiceCallback callback)
Functionality as
getReferenceSetWithAugmentation but with the addition of a callback
interface to report the result or failure of the method. |
Object |
ReferenceServiceImpl.renderIdentifier(T2Reference id,
Class<?> leafClass,
ReferenceContext context) |
Identified |
ReferenceServiceImpl.resolveIdentifier(T2Reference id,
Set<Class<ExternalReferenceSPI>> ensureTypes,
ReferenceContext context)
Perform recursive identifier resolution, building a collection structure
of Identified objects, any collection elements being IdentifiedLists of
Identified subclasses.
|
void |
AbstractReferenceServiceImpl.resolveIdentifierAsynch(T2Reference id,
Set<Class<ExternalReferenceSPI>> ensureTypes,
ReferenceContext context,
ReferenceServiceResolutionCallback callback)
Wraps the synchronous form, using the executeRunnable method to schedule
it.
|
Iterator<ContextualizedT2Reference> |
ReferenceServiceImpl.traverseFrom(T2Reference source,
int desiredDepth)
Initiates a traversal of the specified t2reference, traversing to
whatever level of depth is required such that all identifiers returned
within the iterator have the specified depth.
|
Modifier and Type | Method and Description |
---|---|
boolean |
InMemoryListDao.delete(IdentifiedList<T2Reference> theList) |
boolean |
ReferenceServiceImpl.delete(List<T2Reference> references) |
ErrorDocument |
ErrorDocumentServiceImpl.registerError(String message,
Set<T2Reference> errors,
int depth,
ReferenceContext context) |
IdentifiedList<T2Reference> |
ListServiceImpl.registerList(List<T2Reference> items,
ReferenceContext context) |
void |
InMemoryListDao.store(IdentifiedList<T2Reference> theList) |
Constructor and Description |
---|
ContextualizedT2ReferenceImpl(T2Reference ref,
int[] context) |
Modifier and Type | Method and Description |
---|---|
T2Reference |
DummyReferenceSet.getId() |
Modifier and Type | Method and Description |
---|---|
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
|
Modifier and Type | Method and Description |
---|---|
Map<String,T2Reference> |
Job.getData()
The actual data carried by this (partial) Job object is in the form of a
map, where the keys of the map are Strings identifying the named input
and the values are Strings containing valid data identifiers within the
context of a visible DataManager object (see CloudOne specification for
further information on the DataManager system)
|
Modifier and Type | Method and Description |
---|---|
void |
NonExecutableActivity.executeAsynch(Map<String,T2Reference> data,
AsynchronousActivityCallback callback)
Attempting to run a NonExecutableActivity will always fail.
|
void |
AsynchronousActivity.executeAsynch(Map<String,T2Reference> data,
AsynchronousActivityCallback callback)
Invoke the activity in an asynchronous manner.
|
abstract void |
AbstractAsynchronousActivity.executeAsynch(Map<String,T2Reference> data,
AsynchronousActivityCallback callback)
Request an asynchronous invocation of the activity on the specified data.
|
Set<MonitorableProperty<?>> |
MonitorableAsynchronousActivity.executeAsynchWithMonitoring(Map<String,T2Reference> data,
AsynchronousActivityCallback callback)
This has the same invocation semantics as
AsynchronousActivity .executeAsynch and all
implementations should also implement that method, with the difference
that this one returns immediately with a set of monitorable properties
which represent monitorable or steerable state within the invocation
itself. |
void |
AsynchronousActivityCallback.receiveResult(Map<String,T2Reference> data,
int[] index)
Push a map of named identifiers out to the invocation layer which is then
responsible for wrapping them up into an appropriate Job object and
sending it up the dispatch stack.
|
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
|
Modifier and Type | Method and Description |
---|---|
Map<String,T2Reference> |
DispatchResultEvent.getData()
The result contains a map of named EntityIdentifier instances
corresponding to the result data.
|
Map<String,T2Reference> |
DispatchJobEvent.getData()
The actual data carried by this dispatch job event object is in the form
of a map, where the keys of the map are Strings identifying the named
input and the values are Strings containing valid data identifiers within
the context of a visible DataManager object (see CloudOne specification
for further information on the DataManager system)
|
Constructor and Description |
---|
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
|
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 |
---|---|
void |
Loop.ConditionCallBack.receiveResult(Map<String,T2Reference> data,
int[] index) |
void |
Invoke.InvokeCallBack.receiveResult(Map<String,T2Reference> data,
int[] index) |
Modifier and Type | Method and Description |
---|---|
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.