getInput: Obtains the initializedInput

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

Description

Obtains the initializedInput

Usage

getInput(object)

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

Arguments

object

The AnalysisPipeline or StreamingAnalysisPipeline object

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

Value

Dataframe for an AnalysisPipeline & SparkDataFrame for a StreamingAnalysisPipeline

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

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

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