Class for creating and working with meta-pipelines
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'
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.
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