analysisPipelines (version 1.0.2)

getInput: Obtains the initializedInput

Description

Obtains the initializedInput

Usage

getInput(object)
# S4 method for BaseAnalysisPipeline
getInput(object)

Arguments

object

The AnalysisPipeline or StreamingAnalysisPipeline object

Value

Dataframe for an AnalysisPipeline & SparkDataFrame for a StreamingAnalysisPipeline

Details

Obtains the input from the 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, getLoggerDetails, getOutputById, getPipelinePrototype, getPipeline, getRegistry, initDfBasedOnType, initialize,BaseAnalysisPipeline-method, loadMetaPipeline, loadPipeline, loadPredefinedFunctionRegistry, loadRegistry, prepExecution, registerFunction, savePipeline, saveRegistry, setInput, setLoggerDetails, updateObject, visualizePipeline

Examples

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