BaseAnalysisPipeline-class {analysisPipelines}R Documentation

Base class for AnalysisPipeline and StreamingAnalysisPipeline objects


Base class for AnalysisPipeline and StreamingAnalysisPipeline objects


The class which holds the metadata including the registry of available functions, the data on which the pipeline is to be applied, as well as the pipeline itself, and serves as the base class for various types of Pipeline objects such as Batch and Streaming.

This base class which contains the slots related to the registry, pipeline and output can be extended to create custom class for specific scenarios if required.

In the documentation, objects of classes which are subclasses of this class are referred to as 'Pipeline' objects



A tibble which holds functions to be called


A list containing details of the execution, such as topological ordering of functions to be executed, dependency map of functions, as well as logger configuration


A list which holds all the functions output

See Also

Other Package core functions: MetaAnalysisPipeline-class, assessEngineSetUp, checkSchemaMatch, createPipelineInstance, exportAsMetaPipeline, generateOutput, genericPipelineException, getInput, getLoggerDetails, getOutputById, getPipelinePrototype, getPipeline, getRegistry, initDfBasedOnType, initialize,BaseAnalysisPipeline-method, loadMetaPipeline, loadPipeline, loadPredefinedFunctionRegistry, loadRegistry, prepExecution, registerFunction, savePipeline, saveRegistry, setInput, setLoggerDetails, updateObject, visualizePipeline

[Package analysisPipelines version 1.0.2 Index]