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

  • Method Summary

    Modifier and Type
    Method
    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 java.lang.AutoCloseable

    close

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

    addPipeline, getDataFactory, getProperty, isClosed, isConcurrent, process

  • Constructor Details

    • SimpleCloudEngine

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

  • Method Details

    • 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>