◆ addService()
void fiftyone.pipeline.core.flowelements.Pipeline.addService | ( | PipelineService | service | ) |
Add a service to be used by this Pipeline.
If the service supports Closeable or AutoCloseable, it will be closed automatically when the pipeline is closed.
- Parameters
-
- service -
◆ addServices()
boolean fiftyone.pipeline.core.flowelements.Pipeline.addServices ( Collection< PipelineService > services ) Add a collection of services.
If the services support Closeable or AutoCloseable, they will be closed automatically when the pipeline is closed.
- Parameters
-
- services - to be added
- Returns
- true if successfully added
◆ createFlowData()
◆ getElement()
<T extends FlowElement> T fiftyone.pipeline.core.flowelements.Pipeline.getElement ( Class< T > type ) Get the specified element from the pipeline.
If the pipeline contains multiple elements of the requested type, this method will return null.
- Parameters
-
- type - the type of the FlowElement to get
- <T> - the type of the FlowElement to get
- Returns
- An instance of the specified FlowElement if the pipeline contains one. Null is returned if there is no such instance or there are multiple instances of that type.
◆ getElementAvailableProperties()
Map<String, Map<String, ElementPropertyMetaData> > fiftyone.pipeline.core.flowelements.Pipeline.getElementAvailableProperties ( ) Get the map of available properties for an FlowElement#getElementDataKey().
The map returned contains the ElementPropertyMetaDatas keyed on the name field.
- Returns
- an immutable map of available properties
◆ getEvidenceKeyFilter()
EvidenceKeyFilter fiftyone.pipeline.core.flowelements.Pipeline.getEvidenceKeyFilter ( ) Get the evidence keys used by all the FlowElements in the Pipeline.
- Returns
- merged list of evidence keys
◆ getFlowElements()
List<FlowElement> fiftyone.pipeline.core.flowelements.Pipeline.getFlowElements ( ) Get list of the flow elements that are part of this pipeline.
- Returns
- an immutable list of the flow elements
◆ getServices()
List<PipelineService> fiftyone.pipeline.core.flowelements.Pipeline.getServices ( ) Returns the an unmodified list of services that this Pipeline is monitoring.
- Returns
- immutable list of pipeline services
◆ isClosed()
◆ isConcurrent()
boolean fiftyone.pipeline.core.flowelements.Pipeline.isConcurrent ( ) True if any of the FlowElements in this pipeline will create multiple threads and execute in parallel.
False otherwise.
- Returns
- true if any FlowElements are concurrent