Class for constructing Analysis Pipelines for streaming analyeses
Inherits the base class BaseAnalysisPipeline class which holds the metadata including the registry of available functions, the data on which the pipeline is to be applied, as well as the pipeline itself
This class currently only supports Apache Spark Structured Streaming, implemented through the SparkR interface
input
The input Spark DataFrame on which analysis is to be performed
originalSchemaDf
Empty Spark DataFrame representing the schema of the input
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.