StreamingAnalysisPipeline-class: Class for constructing Analysis Pipelines for streaming...

Description Details Slots

Description

Class for constructing Analysis Pipelines for streaming analyeses

Details

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

Slots

input

The input Spark DataFrame on which analysis is to be performed

originalSchemaDf

Empty Spark DataFrame representing the schema of the input


analysisPipelines documentation built on July 1, 2020, 7:09 p.m.