stream (version 2.0-1)

DSAggregate: Data Stream Aggregator Base Classes

Description

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

Usage

DSAggregate(...)
# S3 method for DSAggregate
update(object, dsd, n = 1, return = c("nothing", "model"), ...)
# S3 method for DSAggregate
get_points(x, ...)
# S3 method for 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.

Author

Michael Hahsler

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: DSClassifier(), DSC(), DSOutlier(), DSRegressor(), DST_SlidingWindow(), DST_WriteStream(), DST(), evaluate, predict(), stream_pipeline, update()

Other DSAggregate: DSAggregate_Sample(), DSAggregate_Window()

Examples

DSAggregate()