Man pages for analysisPipelines
Compose Interoperable Analysis Pipelines & Put Them in Production

AnalysisPipeline-classClass for constructing Analysis Pipelines for batch/ one-time...
analysisPipelinesanalysisPipelines
assessEngineSetUpAssesses engine (R, Spark, Python, Spark Structured...
BaseAnalysisPipeline-classBase class for 'AnalysisPipeline' and...
bivarPlotsBi-Variate Plot
castKafkaStreamAsStringConnect to a Spark session
CheckColumnTypeCheck for type of column
checkSchemaCompare the schemas of two dataframes
checkSchemaMatchChecks the schema of the input to a Pipeline object against...
computeEdgesComputes edges (dependencies) in a pipeline given the joined...
convertKafkaValueFromJsonConnect to a Spark session
correlationMatPlotCorrelation Matrix Plot
createPipelineInstanceCreate a Pipeline object from a meta-pipeline
dot-analysisPipelinesEnvirThis section defines the environment which the package uses...
dot-getCacheThis is an internal function which returns the cache from the...
dot-saveMetaPipelineA method definition for saving meta-pipelines, called when...
dot-setRegistryInternal function used to set the registry object in case of...
dot-updateRegistryThis is an internal function used to update the registry, in...
dot-visualizeMetaPipelineA method definition for visualizing meta-pipelines, called...
exportAsMetaPipelineMethod to export a meta-pipeline
generateOutputGenerate a list of outputs from Pipeline objects
generateReportGenerate a HTML report from an 'AnalysisPipeline' object
genericPipelineExceptionDefault exception for pipeline functions
getDatatypeGet Data Type
getEndPointsObtains end nodes in a graph given nodes and edges
getFeaturesForPyClassificationExtracts selected columns from a data frame as a Python array
getInputObtains the initializedInput
getLoggerDetailsObtains the logger configuration for the pipeline
getOutputByIdObtains a specific output
getPipelineObtain the pipeline
getPipelinePrototypeObtain the prototype of the functions in the pipeline
getRegistryObtains the function registry
getResponseObtains the response term from the formula
getStartingPointsObtains starting nodes in a graph given nodes and edges
getTargetForPyClassificationExtracts selected column from a data frame a binary class...
getTermObtains the dependency term from the formula
getUpstreamDependenciesObtains upstream dependencies for 'AnalysisPipeline' objects
identifyTopLevelRecursivelyRecursive function to identify the toplogical levels of the...
identifyTopologicalLevelsIdentifies the topological levels of the functions in a...
ignoreColsIgnores the columns in the loaded dataframe object
initDfBasedOnTypeinitializes the 'AnalysisPipeline' object with the input...
initializeLoggersintializes the loggers with the required appenders and layout...
initialize-methodsThis is the constructor for the BaseAnalysisPipeline class
isDependencyParamChecks if the parameter is the dependency parameter
loadMetaPipelineLoad a meta-pipeline
loadPipelineLoads the 'AnalysisPipeline' or 'StreamingAnalysisPipeline'...
loadPredefinedFunctionRegistryLoading the registry of predefined functions
loadRegistryLoads a function registry from a file
MetaAnalysisPipeline-classClass for creating and working with meta-pipelines
multiVarOutlierPlotMulti-Variate Outlier Plot
outlierPlotOutlier detection plot
prepExecutionPrepare the pipleline for execution
registerFunctionRegister a user-defined function to be used with a...
savePipelineSaves the 'AnalysisPipeline' or 'StreamingAnalysisPipeline'...
saveRegistrySaves the registry to the file system
setInputSets the input for an 'AnalysisPipeline' or...
setLoggerDetailsSets the logger configuration for the pipeline
setPythonEnvirSets the python environment to be used
setUpstreamDependenciesSets upstream dependencies for the entire pipeline
sparkRSessionCreateIfNotPresentConnect to a Spark session
StreamingAnalysisPipeline-classClass for constructing Analysis Pipelines for streaming...
univarCatDistPlotsUnivariate Categoric Distribution
updateObjectUpdate the 'AnalysisPipeline' or 'StreamingAnalysisPipeline'...
visualizePipelineVisualizes the pipeline as a graph
analysisPipelines documentation built on July 1, 2020, 7:09 p.m.