pipeline.developerexamples.cloudengine.flowelements

Class SimpleCloudEngine

java.lang.Object

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

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

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

pipeline.developerexamples.cloudengine.flowelements.SimpleCloudEngine

All Implemented Interfaces:

fiftyone.pipeline.core.flowelements.FlowElement<StarSignData,fiftyone.pipeline.engines.data.AspectPropertyMetaData>, fiftyone.pipeline.engines.flowelements.AspectEngine<StarSignData,fiftyone.pipeline.engines.data.AspectPropertyMetaData>, fiftyone.pipeline.engines.flowelements.CloudAspectEngine<StarSignData,fiftyone.pipeline.engines.data.AspectPropertyMetaData>, AutoCloseable

public class SimpleCloudEngine
extends CloudAspectEngineBase<StarSignData>

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
SimpleCloudEngine(org.slf4j.Logger logger, fiftyone.pipeline.core.data.factories.ElementDataFactory<StarSignData> dataFactory)

Method Summary

Modifier and Type	Method and Description
String	getDataSourceTier()
String	getElementDataKey()
fiftyone.pipeline.core.data.EvidenceKeyFilter	getEvidenceKeyFilter()
List<fiftyone.pipeline.engines.data.AspectPropertyMetaData>	getProperties()
protected void	processEngine(fiftyone.pipeline.core.data.FlowData data, StarSignData aspectData)
protected void	unmanagedResourcesCleanup()

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

createAPVMap, getRequestEngine, getTypedDataKey, processCloudEngine, 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, getDataFactory, getPipelines, getProperty, isClosed, isConcurrent, process

Methods inherited from class java.lang.Object

clone, equals, finalize, 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, getProperty, isClosed, isConcurrent, process

Methods inherited from interface java.lang.AutoCloseable

close

Constructor Detail

SimpleCloudEngine

public SimpleCloudEngine(org.slf4j.Logger logger,
                         fiftyone.pipeline.core.data.factories.ElementDataFactory<StarSignData> dataFactory)

Method Detail

getProperties

public List<fiftyone.pipeline.engines.data.AspectPropertyMetaData> getProperties()

Specified by:

getProperties in interface fiftyone.pipeline.core.flowelements.FlowElement<StarSignData,fiftyone.pipeline.engines.data.AspectPropertyMetaData>

Overrides:

getProperties in class CloudAspectEngineBase<StarSignData>

getDataSourceTier

public String getDataSourceTier()

Specified by:

getDataSourceTier in interface fiftyone.pipeline.engines.flowelements.AspectEngine<StarSignData,fiftyone.pipeline.engines.data.AspectPropertyMetaData>

Overrides:

getDataSourceTier in class CloudAspectEngineBase<StarSignData>

getElementDataKey

public String getElementDataKey()

Specified by:

getElementDataKey in interface fiftyone.pipeline.core.flowelements.FlowElement<StarSignData,fiftyone.pipeline.engines.data.AspectPropertyMetaData>

Specified by:

getElementDataKey in class fiftyone.pipeline.core.flowelements.FlowElementBase<StarSignData,fiftyone.pipeline.engines.data.AspectPropertyMetaData>

getEvidenceKeyFilter

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

Specified by:

getEvidenceKeyFilter in interface fiftyone.pipeline.core.flowelements.FlowElement<StarSignData,fiftyone.pipeline.engines.data.AspectPropertyMetaData>

Specified by:

getEvidenceKeyFilter in class fiftyone.pipeline.core.flowelements.FlowElementBase<StarSignData,fiftyone.pipeline.engines.data.AspectPropertyMetaData>

processEngine

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

Overrides:

processEngine in class CloudAspectEngineBase<StarSignData>

unmanagedResourcesCleanup

protected void unmanagedResourcesCleanup()

Specified by:

unmanagedResourcesCleanup in class fiftyone.pipeline.core.flowelements.FlowElementBase<StarSignData,fiftyone.pipeline.engines.data.AspectPropertyMetaData>