◆ PipelineBuilderBase()
fiftyone.pipeline.core.flowelements.PipelineBuilderBase< T extends PipelineBuilderBase >.PipelineBuilderBase | ( | ILoggerFactory | loggerFactory | ) |
Construct a new instance.
- Parameters
-
- loggerFactory - the ILoggerFactory used to create any loggers required by instances being built by the builder
Member Function Documentation
◆ addFlowElement()
T fiftyone.pipeline.core.flowelements.PipelineBuilderBase< T extends PipelineBuilderBase >.addFlowElement ( FlowElement element ) Add a FlowElement to the Pipeline to be run in series.
- Parameters
-
- element - to add
- Returns
- this builder
◆ addFlowElementsParallel()
T fiftyone.pipeline.core.flowelements.PipelineBuilderBase< T extends PipelineBuilderBase >.addFlowElementsParallel ( FlowElement [] elements ) Add an array of FlowElements to the Pipeline to be run in parallel.
Must contain more than 1 element.
- Parameters
-
- elements - to add
- Returns
- this builder
◆ build()
Pipeline fiftyone.pipeline.core.flowelements.PipelineBuilderBase< T extends PipelineBuilderBase >.build ( ) throws Exception Build the Pipeline using the FlowElements added.
- Returns
- new Pipeline instance
◆ setAutoCloseElements()
T fiftyone.pipeline.core.flowelements.PipelineBuilderBase< T extends PipelineBuilderBase >.setAutoCloseElements ( boolean autoClose ) Configure the Pipeline to either call dispose on it's child FlowElements when it is disposed or not.
- Parameters
-
- autoClose - true if the Pipeline should call dispose on it's child elements when it is disposed
- Returns
- this builder
◆ setSuppressProcessException()
T fiftyone.pipeline.core.flowelements.PipelineBuilderBase< T extends PipelineBuilderBase >.setSuppressProcessException ( boolean suppress ) Configure the Pipeline to either suppress exceptions added to FlowData#getErrors() during processing or to throw them as an aggregate exception once processing is complete.
- Parameters
-
- suppress - if true then Pipeline will suppress exceptions added to FlowData#getErrors()
- Returns
- this builder