Data Stream Aggregator Base Classes

Abstract base classes for all DSAggregate (Data Stream Aggregator) classes to aggregate streams. DSAggreagate is a DST task.

Usage

DSAggregate(...)

# S3 method for class 'DSAggregate'
update(object, dsd, n = 1, return = c("nothing", "model"), ...)

# S3 method for class 'DSAggregate'
get_points(x, ...)

# S3 method for class 'DSAggregate'
get_weights(x, ...)

Arguments

...

Further arguments.

dsd

a data stream object.

n

the number of data points used for the update.

return

a character string indicating what update returns. The default is "nothing" and "model" returns the aggregated data.

x, object

a concrete implementation of DSAggregate.

Details

The DSAggreagate class cannot be instantiated, but it serve as a base class from which other DSAggregate subclasses inherit.

Data stream operators use update.DSAggregate() to process new data from the DSD stream. The result of the operator can be obtained via get_points() and get_weights() (if available).

See also

Other DST: DSC(), DSClassifier(), DSOutlier(), DSRegressor(), DST(), DST_SlidingWindow(), DST_WriteStream(), evaluate, predict, stream_pipeline, update

Other DSAggregate: DSAggregate_Sample(), DSAggregate_Window()

Author

Michael Hahsler

Examples

DSAggregate()
#> DSAggregate is an abstract class and cannot be instantiated!
#> 
#> Available subclasses in ‘package:stream’ are:
#> 	DSAggregate_Sample,
#> 	DSAggregate_Window
#> 
#> To get more information in R Studio, type ‘DSAggregate_’ and hit the Tab key.