◆ AspectDataBase() [1/3]
fiftyone.pipeline.engines.data.AspectDataBase.AspectDataBase | ( | Logger | logger, |
FlowData | flowData, | ||
AspectEngine<? extends AspectData, ? extends AspectPropertyMetaData > | engine | ||
) |
Constructs a new instance with a non-thread-safe, case-insensitive Map as the underlying storage.
- Parameters
-
- logger - used for logging
- flowData - the FlowData instance this element data will be associated with
- engine - the engine which created the instance
◆ AspectDataBase() [2/3]
fiftyone.pipeline.engines.data.AspectDataBase.AspectDataBase ( Logger logger, FlowData flowData, AspectEngine<? extends AspectData,? extends AspectPropertyMetaData > engine, MissingPropertyService missingPropertyService ) Constructs a new instance with a non-thread-safe, case-insensitive Map as the underlying storage.
- Parameters
-
- logger - used for logging
- flowData - the FlowData instance this element data will be associated with
- engine - the engine which created the instance
- missingPropertyService - service used to determine the reason for a property value being missing
◆ AspectDataBase() [3/3]
fiftyone.pipeline.engines.data.AspectDataBase.AspectDataBase ( Logger logger, FlowData flowData, AspectEngine<? extends AspectData,? extends AspectPropertyMetaData > engine, MissingPropertyService missingPropertyService, Map< String, Object > map ) Constructs a new instance with a custom Map as the underlying storage.
- Parameters
-
- logger - used for logging
- flowData - the FlowData instance this element data will be associated with
- engine - the engine which created the instance
- missingPropertyService - service used to determine the reason for a property value being missing
Member Function Documentation
◆ addEngine()
void fiftyone.pipeline.engines.data.AspectDataBase.addEngine ( AspectEngine<? extends AspectData,? extends AspectPropertyMetaData > engine ) Add an engine to the list of engines which have generated the data within this instance.
- Parameters
-
- engine - engine adding data
◆ addProcessCallable()
void fiftyone.pipeline.engines.data.AspectDataBase.addProcessCallable ( ProcessCallable runnable ) Add a callable which will run a AspectEngine#process(FlowData) method to populate this instance.
The property accessors will only complete once all such tasks have completed.
- Parameters
-
- runnable - processing runnable
◆ asKeyMap()
Map<String, Object> fiftyone.pipeline.engines.data.AspectDataBase.asKeyMap ( ) Get the data contained in this instance as a read only Map.
- Returns
- the data
Implements fiftyone.pipeline.core.data.Data.
◆ get()
Object fiftyone.pipeline.engines.data.AspectDataBase.get ( String propertyName ) throws PropertyMissingException Gets the value stored using the specified key with full checks against the MissingPropertyService.
- Parameters
-
- propertyName - to get the value for
- Returns
- value of the property
- Exceptions
-
- PropertyMissingException - the property was not found
Implements fiftyone.pipeline.core.data.Data.
◆ getEngines()
List<AspectEngine<? extends AspectData,? extends AspectPropertyMetaData> > fiftyone.pipeline.engines.data.AspectDataBase.getEngines ( ) Get the engines that generated the data withing this data instance.
- Returns
- engines which generated the data
Implements fiftyone.pipeline.engines.data.AspectData.
◆ getProcessFuture()
Future<?> fiftyone.pipeline.engines.data.AspectDataBase.getProcessFuture ( ) If the engine is configured for lazy loading, this property returns a Future that will complete once the engine has finished processing.
Otherwise, it will be null.
- Returns
- lazy loading future or null
Implements fiftyone.pipeline.engines.data.AspectData.