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 |
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.