setInput: Sets the input for an 'AnalysisPipeline' or...

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

Description

Sets the input for an AnalysisPipeline or StreamingAnalysisPipeline object

Usage

setInput(object, input, filePath = "")

## S4 method for signature '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)

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

Value

Updated AnalysisPipeline StreamingAnalysisPipeline object

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

  library(analysisPipelines)
  pipelineObj <- AnalysisPipeline()
  pipelineObj %>>% setInput(input = iris) -> pipelineObj

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