Files in Mu-Sigma/analysis-pipelines
Compose Interoperable Analysis Pipelines & Put Them in Production
.Rbuildignore
.gitattributes
.gitignore
DESCRIPTION
LICENSE
NAMESPACE
R/analysisPipelines_package.R
R/core-functions-batch.R
R/core-functions-meta-pipelines.R
R/core-functions.R
R/core-streaming-functions.R
R/r-batch-eda-utilities.R
R/r-helper-utilites-python.R
R/spark-structured-streaming-utilities.R
R/sysdata.rda
R/zzz.R
README.md
analysisPipelines.Rproj
data-raw/predefFunctions.R
inst/data-icon.png
inst/logging.png
inst/output-icon.png
inst/param-icon.png
inst/pipelineViz1.png
inst/pipelineViz2.png
inst/python-logo.png
inst/python/sampleFunctions.py
inst/r-logo.png
inst/report.Rmd
inst/report1.png
inst/report2.png
inst/report3.png
inst/spark-logo.png
inst/spark-structured-streaming-logo.png
inst/styles.css
knit-vignettes/2.Analysis_pipelines_for_working_with_Spark_DataFrames_for_one-time_batch_analyses.html
knit-vignettes/3.Analysis_pipelines_for_working_with_Python_functions.html
knit-vignettes/4.Interoperable_analysis_pipelines.html
knit-vignettes/5.Streaming_Analysis_Pipelines_for_working_with_Apache_Spark_Structured_Streaming.html
man/AnalysisPipeline-class.Rd
man/BaseAnalysisPipeline-class.Rd
man/CheckColumnType.Rd
man/MetaAnalysisPipeline-class.Rd
man/StreamingAnalysisPipeline-class.Rd
man/analysisPipelines.Rd
man/assessEngineSetUp.Rd
man/bivarPlots.Rd
man/castKafkaStreamAsString.Rd
man/checkSchema.Rd
man/checkSchemaMatch.Rd
man/computeEdges.Rd
man/convertKafkaValueFromJson.Rd
man/correlationMatPlot.Rd
man/createPipelineInstance.Rd
man/dot-analysisPipelinesEnvir.Rd
man/dot-getCache.Rd
man/dot-saveMetaPipeline.Rd
man/dot-setRegistry.Rd
man/dot-updateRegistry.Rd
man/dot-visualizeMetaPipeline.Rd
man/exportAsMetaPipeline.Rd
man/generateOutput.Rd
man/generateReport.Rd
man/genericPipelineException.Rd
man/getDatatype.Rd
man/getEndPoints.Rd
man/getFeaturesForPyClassification.Rd
man/getInput.Rd
man/getLoggerDetails.Rd
man/getOutputById.Rd
man/getPipeline.Rd
man/getPipelinePrototype.Rd
man/getRegistry.Rd
man/getResponse.Rd
man/getStartingPoints.Rd
man/getTargetForPyClassification.Rd
man/getTerm.Rd
man/getUpstreamDependencies.Rd
man/identifyTopLevelRecursively.Rd
man/identifyTopologicalLevels.Rd
man/ignoreCols.Rd
man/initDfBasedOnType.Rd
man/initialize-methods.Rd
man/initializeLoggers.Rd
man/isDependencyParam.Rd
man/loadMetaPipeline.Rd
man/loadPipeline.Rd
man/loadPredefinedFunctionRegistry.Rd
man/loadRegistry.Rd
man/multiVarOutlierPlot.Rd
man/outlierPlot.Rd
man/prepExecution.Rd
man/registerFunction.Rd
man/savePipeline.Rd
man/saveRegistry.Rd
man/setInput.Rd
man/setLoggerDetails.Rd
man/setPythonEnvir.Rd
man/setUpstreamDependencies.Rd
man/sparkRSessionCreateIfNotPresent.Rd
man/univarCatDistPlots.Rd
man/updateObject.Rd
man/visualizePipeline.Rd
vignettes/Analysis_pipelines_for_working_with_Python_functions.Rmd
vignettes/Analysis_pipelines_for_working_with_R_dataframes.Rmd
vignettes/Analysis_pipelines_for_working_with_sparkR.Rmd
vignettes/Interoperable_Pipelines.Rmd
vignettes/Meta_Pipelines.Rmd
vignettes/Streaming_pipelines_for_working_Apache_Spark_Structured_Streaming.Rmd
vignettes/Using_pipelines_inside_shiny_widgets.Rmd
