analysisPipelines (version 1.0.2)

setInput: Sets the input for an AnalysisPipeline or StreamingAnalysisPipeline object

Description

Sets the input for an AnalysisPipeline or StreamingAnalysisPipeline object

Usage

setInput(object, input, filePath = "")
# S4 method for BaseAnalysisPipeline
setInput(object, input, filePath = "")

Arguments

object

object that contains input, pipeline, registry and output

input

the input data frame

filePath

path to the file which needs to be read (currently supports .csv files)

Value

Updated AnalysisPipeline StreamingAnalysisPipeline object

Details

Assigns the input to the pipeline for an AnalysisPipeline or StreamingAnalysisPipeline object

This method is implemented on the base class as it is a shared functionality types of Analysis Pipelines which extend this class

See Also

Other Package core functions: BaseAnalysisPipeline-class, 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, setLoggerDetails, updateObject, visualizePipeline

Examples

# NOT RUN {
  library(analysisPipelines)
  pipelineObj <- AnalysisPipeline()
  pipelineObj %>>% setInput(input = iris) -> pipelineObj
# }