51Degrees Pipeline Java
4.4
Abstract base class for all Pipeline builders.
The default implementation is PipelineBuilder.
| PipelineBuilderBase ()
Construct a new instance using the default ILoggerFactory implementation returned by the LoggerFactory#getILoggerFactory() method.
| |
| PipelineBuilderBase (ILoggerFactory loggerFactory)
Construct a new instance. More...
| |
| Pipeline | build () throws Exception |
| T | addFlowElement (FlowElement element) |
| T | addFlowElementsParallel (FlowElement[] elements) |
| T | addService (PipelineService service)
Add a service to the builder which will be needed by any of the elements being added to the pipeline. More...
|
| T | setAutoCloseElements (boolean autoClose)
Configure the Pipeline to either call dispose on it's child FlowElements when it is disposed or not. More...
|
| T | 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. More...
|
| List< FlowElement > | getFlowElements () |
| final ILoggerFactory | loggerFactory
The ILoggerFactory used to create any loggers required by instances being built by the builder.
|
| final Logger | logger
Logger created from loggerFactory to allow logging in this builder.
|
| final List< FlowElement > | flowElements = new ArrayList<>()
List of flow elements to add to the Pipeline.
|
| final List< PipelineService > | services = new ArrayList<>()
List of services to be managed by the Pipeline.
|
| boolean | autoCloseElements = false |
| fiftyone.pipeline.core.flowelements.PipelineBuilderBase< T extends PipelineBuilderBase >.PipelineBuilderBase | ( | ILoggerFactory | loggerFactory | ) |
Construct a new instance.
| T fiftyone.pipeline.core.flowelements.PipelineBuilderBase< T extends PipelineBuilderBase >.addFlowElement | ( | FlowElement | element | ) |
Add a FlowElement to the Pipeline to be run in series.
| 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.
| T fiftyone.pipeline.core.flowelements.PipelineBuilderBase< T extends PipelineBuilderBase >.addService | ( | PipelineService | service | ) |
Add a service to the builder which will be needed by any of the elements being added to the pipeline.
This should be used when calling PipelineBuilderFromConfiguration#buildFromConfiguration(PipelineOptions).
See PipelineService for more details.
| void fiftyone.pipeline.core.flowelements.PipelineBuilderBase< T extends PipelineBuilderBase >.addServicesToPipeline | ( | Pipeline | pipeline | ) |
Add all known services to a Pipeline to be managed.
| Pipeline fiftyone.pipeline.core.flowelements.PipelineBuilderBase< T extends PipelineBuilderBase >.build | ( | ) | throws Exception |
Build the Pipeline using the FlowElements added.
| 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.
| 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.