fiftyone.pipeline.cloudrequestengine.flowelements

Class PropertyKeyedCloudEngineBase<TData extends MultiProfileData<TProfile>,TProfile extends AspectData>

java.lang.Object

fiftyone.pipeline.core.flowelements.FlowElementBase<TData,TProperty>

fiftyone.pipeline.engines.flowelements.AspectEngineBase<TData,AspectPropertyMetaData>

fiftyone.pipeline.cloudrequestengine.flowelements.CloudAspectEngineBase<TData>

fiftyone.pipeline.cloudrequestengine.flowelements.PropertyKeyedCloudEngineBase<TData,TProfile>

Type Parameters:

TData - the type of AspectData returned by this engine

TProfile - the type of items in the list returned by this engine

All Implemented Interfaces:

fiftyone.pipeline.core.flowelements.FlowElement<TData,AspectPropertyMetaData>, AspectEngine<TData,AspectPropertyMetaData>, CloudAspectEngine<TData,AspectPropertyMetaData>, AutoCloseable

public abstract class PropertyKeyedCloudEngineBase<TData extends MultiProfileData<TProfile>,TProfile extends AspectData>
extends CloudAspectEngineBase<TData>

A specialised type of CloudAspectEngineBase that has the functionality to support returning a list of matching AspectData profiles rather than a single item.

Nested Class Summary

Nested classes/interfaces inherited from class fiftyone.pipeline.cloudrequestengine.flowelements.CloudAspectEngineBase

CloudAspectEngineBase.RequestEngineAccessor

Nested classes/interfaces inherited from class fiftyone.pipeline.core.flowelements.FlowElementBase

fiftyone.pipeline.core.flowelements.FlowElementBase.DataFactoryInternal<T extends fiftyone.pipeline.core.data.ElementData>, fiftyone.pipeline.core.flowelements.FlowElementBase.DataFactorySimple<T extends fiftyone.pipeline.core.data.ElementData>

Nested classes/interfaces inherited from interface fiftyone.pipeline.core.flowelements.FlowElement

fiftyone.pipeline.core.flowelements.FlowElement.DataFactory<T extends fiftyone.pipeline.core.data.ElementData>

Field Summary

Fields inherited from class fiftyone.pipeline.engines.flowelements.AspectEngineBase

cache, missingPropertyService

Fields inherited from class fiftyone.pipeline.core.flowelements.FlowElementBase

logger, typedKey

Constructor Summary

Constructors

Constructor and Description
PropertyKeyedCloudEngineBase(org.slf4j.Logger logger, fiftyone.pipeline.core.data.factories.ElementDataFactory<TData> aspectDataFactory)

Method Summary

Modifier and Type	Method and Description
protected abstract TProfile	createProfileData(fiftyone.pipeline.core.data.FlowData flowData)
fiftyone.pipeline.core.data.EvidenceKeyFilter	getEvidenceKeyFilter()
fiftyone.pipeline.core.typed.TypedKey<TData>	getTypedDataKey()
protected void	processEngine(fiftyone.pipeline.core.data.FlowData data, TData aspectData)

Methods inherited from class fiftyone.pipeline.cloudrequestengine.flowelements.CloudAspectEngineBase

createAPVMap, getDataSourceTier, getProperties, getRequestEngine, setRequestEngine

Methods inherited from class fiftyone.pipeline.engines.flowelements.AspectEngineBase

getExecutor, getLazyLoadingConfiguration, managedResourcesCleanup, processInternal, setCache, setLazyLoading

Methods inherited from class fiftyone.pipeline.core.flowelements.FlowElementBase

addPipeline, close, close, finalize, getDataFactory, getElementDataKey, getPipelines, getProperty, isClosed, isConcurrent, process, unmanagedResourcesCleanup

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface fiftyone.pipeline.engines.flowelements.AspectEngine

getExecutor, getLazyLoadingConfiguration, setCache, setLazyLoading

Methods inherited from interface fiftyone.pipeline.core.flowelements.FlowElement

addPipeline, getDataFactory, getElementDataKey, getProperty, isClosed, isConcurrent, process

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

PropertyKeyedCloudEngineBase

public PropertyKeyedCloudEngineBase(org.slf4j.Logger logger,
                                    fiftyone.pipeline.core.data.factories.ElementDataFactory<TData> aspectDataFactory)

Method Detail

getEvidenceKeyFilter

public fiftyone.pipeline.core.data.EvidenceKeyFilter getEvidenceKeyFilter()

Specified by:

getEvidenceKeyFilter in interface fiftyone.pipeline.core.flowelements.FlowElement<TData extends MultiProfileData<TProfile>,AspectPropertyMetaData>

Specified by:

getEvidenceKeyFilter in class fiftyone.pipeline.core.flowelements.FlowElementBase<TData extends MultiProfileData<TProfile>,AspectPropertyMetaData>

processEngine

protected void processEngine(fiftyone.pipeline.core.data.FlowData data,
                             TData aspectData)

Specified by:

processEngine in class AspectEngineBase<TData extends MultiProfileData<TProfile>,AspectPropertyMetaData>

getTypedDataKey

public fiftyone.pipeline.core.typed.TypedKey<TData> getTypedDataKey()

Specified by:

getTypedDataKey in interface fiftyone.pipeline.core.flowelements.FlowElement<TData extends MultiProfileData<TProfile>,AspectPropertyMetaData>

Overrides:

getTypedDataKey in class CloudAspectEngineBase<TData extends MultiProfileData<TProfile>>

createProfileData

protected abstract TProfile createProfileData(fiftyone.pipeline.core.data.FlowData flowData)