A method that all pre-processor classes need to implement. It is the code that aggregates and consolidates input data streams into one output event stream.
preprocess(x, streams, ...)The pre-processor object.
A named list that comprises input data streams. Each input data stream is a data frame comprising fields declared while creating the HSC_PP object.
An additional list of parameters that can be used by the pre-proccessor.
Returns a list that comprises:
obj - A returning pre-processor object. Passed in the subsequent invocation as x.
res - An output event stream. A resulting data frame representing the output event stream that is ordered according to the timestamp / sequence field and comprises all declared fields.
Input streams can be created as
streams -> list(stream1=x1,stream2=x2,....)
where x1 is a data frame and stream1 is the name of the stream. All examnples can be seen in the SeqDetect vignette.