Man pages for analysisPipelines
Compose Interoperable Analysis Pipelines & Put Them in Production
| AnalysisPipeline-class | Class for constructing Analysis Pipelines for batch/ one-time... |
| analysisPipelines | analysisPipelines |
| assessEngineSetUp | Assesses engine (R, Spark, Python, Spark Structured... |
| BaseAnalysisPipeline-class | Base class for 'AnalysisPipeline' and... |
| bivarPlots | Bi-Variate Plot |
| castKafkaStreamAsString | Connect to a Spark session |
| CheckColumnType | Check for type of column |
| checkSchema | Compare the schemas of two dataframes |
| checkSchemaMatch | Checks the schema of the input to a Pipeline object against... |
| computeEdges | Computes edges (dependencies) in a pipeline given the joined... |
| convertKafkaValueFromJson | Connect to a Spark session |
| correlationMatPlot | Correlation Matrix Plot |
| createPipelineInstance | Create a Pipeline object from a meta-pipeline |
| dot-analysisPipelinesEnvir | This section defines the environment which the package uses... |
| dot-getCache | This is an internal function which returns the cache from the... |
| dot-saveMetaPipeline | A method definition for saving meta-pipelines, called when... |
| dot-setRegistry | Internal function used to set the registry object in case of... |
| dot-updateRegistry | This is an internal function used to update the registry, in... |
| dot-visualizeMetaPipeline | A method definition for visualizing meta-pipelines, called... |
| exportAsMetaPipeline | Method to export a meta-pipeline |
| generateOutput | Generate a list of outputs from Pipeline objects |
| generateReport | Generate a HTML report from an 'AnalysisPipeline' object |
| genericPipelineException | Default exception for pipeline functions |
| getDatatype | Get Data Type |
| getEndPoints | Obtains end nodes in a graph given nodes and edges |
| getFeaturesForPyClassification | Extracts selected columns from a data frame as a Python array |
| getInput | Obtains the initializedInput |
| getLoggerDetails | Obtains the logger configuration for the pipeline |
| getOutputById | Obtains a specific output |
| getPipeline | Obtain the pipeline |
| getPipelinePrototype | Obtain the prototype of the functions in the pipeline |
| getRegistry | Obtains the function registry |
| getResponse | Obtains the response term from the formula |
| getStartingPoints | Obtains starting nodes in a graph given nodes and edges |
| getTargetForPyClassification | Extracts selected column from a data frame a binary class... |
| getTerm | Obtains the dependency term from the formula |
| getUpstreamDependencies | Obtains upstream dependencies for 'AnalysisPipeline' objects |
| identifyTopLevelRecursively | Recursive function to identify the toplogical levels of the... |
| identifyTopologicalLevels | Identifies the topological levels of the functions in a... |
| ignoreCols | Ignores the columns in the loaded dataframe object |
| initDfBasedOnType | initializes the 'AnalysisPipeline' object with the input... |
| initializeLoggers | intializes the loggers with the required appenders and layout... |
| initialize-methods | This is the constructor for the BaseAnalysisPipeline class |
| isDependencyParam | Checks if the parameter is the dependency parameter |
| loadMetaPipeline | Load a meta-pipeline |
| loadPipeline | Loads the 'AnalysisPipeline' or 'StreamingAnalysisPipeline'... |
| loadPredefinedFunctionRegistry | Loading the registry of predefined functions |
| loadRegistry | Loads a function registry from a file |
| MetaAnalysisPipeline-class | Class for creating and working with meta-pipelines |
| multiVarOutlierPlot | Multi-Variate Outlier Plot |
| outlierPlot | Outlier detection plot |
| prepExecution | Prepare the pipleline for execution |
| registerFunction | Register a user-defined function to be used with a... |
| savePipeline | Saves the 'AnalysisPipeline' or 'StreamingAnalysisPipeline'... |
| saveRegistry | Saves the registry to the file system |
| setInput | Sets the input for an 'AnalysisPipeline' or... |
| setLoggerDetails | Sets the logger configuration for the pipeline |
| setPythonEnvir | Sets the python environment to be used |
| setUpstreamDependencies | Sets upstream dependencies for the entire pipeline |
| sparkRSessionCreateIfNotPresent | Connect to a Spark session |
| StreamingAnalysisPipeline-class | Class for constructing Analysis Pipelines for streaming... |
| univarCatDistPlots | Univariate Categoric Distribution |
| updateObject | Update the 'AnalysisPipeline' or 'StreamingAnalysisPipeline'... |
| visualizePipeline | Visualizes the pipeline as a graph |
