MetaAnalysisPipeline-class: Class for creating and working with meta-pipelines

In analysisPipelines: Compose Interoperable Analysis Pipelines & Put Them in Production

Description

Class for creating and working with meta-pipelines

Details

This class works with the AnalysisPipeline and StreamingAnalysisPipeline classes, and allows the pipeline to be exported as meta-pipeline. A meta-pipeline is a construct, where the input dataset as well as the arguments to functions in the pipeline are not defined. Only the analysis flow and dependencies are stored.

Slots

pipeline

A tibble which holds functions to be called in the pipeline

pipelinePrototype

An object of class proto from the 'proto' package which maintains the prototype of the functions in the pipeline and their respective arguments

type

A string defining whether it is a batch or streaming pipeline. Acceptable values are 'batch' & 'streaming'

See Also

Other Package core functions: BaseAnalysisPipeline-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

analysisPipelines documentation built on July 1, 2020, 7:09 p.m.