◆ addDataFile()
| void fiftyone.pipeline.engines.flowelements.OnPremiseAspectEngine< TData extends AspectData, TProperty extends AspectPropertyMetaData >.addDataFile | ( | AspectEngineDataFile | dataFile | ) |
Add the specified data file to the engine.
- Parameters
-
- dataFile - the data file to add
◆ getDataFileMetaData() [1/2]
AspectEngineDataFile fiftyone.pipeline.engines.flowelements.OnPremiseAspectEngine< TData extends AspectData, TProperty extends AspectPropertyMetaData >.getDataFileMetaData ( String dataFileIdentifier ) Get the details of a specific data file used by this engine.
- Parameters
-
- dataFileIdentifier - the identifier of the data file to get meta data for. This parameter is ignored if the engine only has one data file
- Returns
- the meta data associated with the specified data file, or null if the engine has no associated data files
◆ getDataFileMetaData() [2/2]
AspectEngineDataFile fiftyone.pipeline.engines.flowelements.OnPremiseAspectEngine< TData extends AspectData, TProperty extends AspectPropertyMetaData >.getDataFileMetaData ( ) Get the details the default data file used by this engine.
- Returns
- the meta data associated with the specified data file, or null if the engine has no associated data files
◆ getDataFiles()
List<AspectEngineDataFile> fiftyone.pipeline.engines.flowelements.OnPremiseAspectEngine< TData extends AspectData, TProperty extends AspectPropertyMetaData >.getDataFiles ( ) Details of the data files used by this engine.
- Returns
- a read only list of data files
◆ getTempDataDirPath()
String fiftyone.pipeline.engines.flowelements.OnPremiseAspectEngine< TData extends AspectData, TProperty extends AspectPropertyMetaData >.getTempDataDirPath ( ) The complete file path to the directory that is used by the engine to store temporary copies of any data files that it uses.
- Returns
- temporary data directory
◆ refreshData() [1/2]
void fiftyone.pipeline.engines.flowelements.OnPremiseAspectEngine< TData extends AspectData, TProperty extends AspectPropertyMetaData >.refreshData ( String dataFileIdentifier ) Causes the engine to reload data from the file at AspectEngineDataFile#getDataFilePath() for the data file matching the given identifier.
Where the engine is built from a byte[], the overload with the byte[] parameter should be called instead. This method is thread-safe so parallel calls to process(FlowData) will resolve as normal.
- Parameters
-
- dataFileIdentifier - the identifier of the data file to update. Must match the value in AspectEngineDataFile#getIdentifier(). If the engine only has a single data file, this parameter is ignored
◆ refreshData() [2/2]
void fiftyone.pipeline.engines.flowelements.OnPremiseAspectEngine< TData extends AspectData, TProperty extends AspectPropertyMetaData >.refreshData ( String dataFileIdentifier, byte [] data ) Causes the engine to reload data from the specified byte[].
Where the engine is built from a data file on disk, this will also update the data file with the new data. This method is thread-safe so parallel calls to 'Process' will resolve as normal.
- Parameters
-
- dataFileIdentifier - the identifier of the data file to update. Must match the value in AspectEngineDataFile#getIdentifier(). If the engine only has a single data file, this parameter is ignored
- data - an in-memory representation of the new data file contents