◆ addPipeline()
void fiftyone.pipeline.core.flowelements.FlowElement< TData extends ElementData, TProperty extends ElementPropertyMetaData >.addPipeline | ( | Pipeline | pipeline | ) |
Called when this element is added to a pipeline.
- Parameters
-
- pipeline - the pipeline that the element has been added to
◆ getDataFactory()
DataFactory<TData> fiftyone.pipeline.core.flowelements.FlowElement< TData extends ElementData, TProperty extends ElementPropertyMetaData >.getDataFactory ( ) Get the factory used to create the element data instances that are populated by this flow element.
- Returns
- the factory for TData
◆ getElementDataKey()
String fiftyone.pipeline.core.flowelements.FlowElement< TData extends ElementData, TProperty extends ElementPropertyMetaData >.getElementDataKey ( ) Get the string name of the key used to access the data populated by this element in the FlowData.
- Returns
- this element's data key string
Implemented in fiftyone.pipeline.cloudrequestengine.flowelements.CloudRequestEngineDefault.
◆ getEvidenceKeyFilter()
EvidenceKeyFilter fiftyone.pipeline.core.flowelements.FlowElement< TData extends ElementData, TProperty extends ElementPropertyMetaData >.getEvidenceKeyFilter ( ) Get a filter that will only include the evidence keys that this element can make use of.
- Returns
- this element's EvidenceKeyFilter
Implemented in fiftyone.pipeline.cloudrequestengine.flowelements.CloudRequestEngineDefault.
◆ getProperties()
List<TProperty> fiftyone.pipeline.core.flowelements.FlowElement< TData extends ElementData, TProperty extends ElementPropertyMetaData >.getProperties ( ) Get details of the properties that this element can populate.
- Returns
- this element's properties as a list
Implemented in fiftyone.pipeline.cloudrequestengine.flowelements.CloudRequestEngineDefault.
◆ getProperty()
TProperty fiftyone.pipeline.core.flowelements.FlowElement< TData extends ElementData, TProperty extends ElementPropertyMetaData >.getProperty ( String name ) Get a property from the properties that this element can populate using its name.
- Parameters
-
- name - the name of the property
- Returns
- the property or null if it is not found
◆ getTypedDataKey()
TypedKey<TData> fiftyone.pipeline.core.flowelements.FlowElement< TData extends ElementData, TProperty extends ElementPropertyMetaData >.getTypedDataKey ( ) Get the typed data key used for retrieving strongly typed element data.
- Returns
- this element's typed data key
◆ isClosed()
boolean fiftyone.pipeline.core.flowelements.FlowElement< TData extends ElementData, TProperty extends ElementPropertyMetaData >.isClosed ( ) Indicates whether the element has been closed using the close() method, either explicitly or as a result of a 'try with resource'.
- Returns
- true if the element has been closed
◆ isConcurrent()
boolean fiftyone.pipeline.core.flowelements.FlowElement< TData extends ElementData, TProperty extends ElementPropertyMetaData >.isConcurrent ( ) ◆ process()
void fiftyone.pipeline.core.flowelements.FlowElement< TData extends ElementData, TProperty extends ElementPropertyMetaData >.process ( FlowData data ) throws Exception Carry out whatever operations this element is designed to do using the FlowData passed.
- Parameters
-
- data - the FlowData instance that provides input evidence and carries the output data to the user.
- Exceptions
-
- Exception - if there was an error while processing. Note that the internal errors will only result in an exception if the Pipeline has been configured not to suppress exceptions using the PipelineBuilder#setSuppressProcessException(boolean) option