Arithmetic operations

Table of Contents

• Sample stream operations
• Windowed sample stream operations

There are a few arithmetic operations are defined for certain types. It is mainly the syntactic sugar for map and merge operations, anyway can be useful sometimes to use therm instead.

Sample stream operations

Sample stream BeanStream<Sample> you can sum, subtract, multiply and divide with another sample stream:

sampleStream1 + sampleStream2
sampleStream1 - sampleStream2
sampleStream1 * sampleStream2
sampleStream1 / sampleStream2

That means both stream are going to be merged together and specified operation will be used as a merge operation.

Windowed sample stream operations

Windowed sample stream BeanStream<Window<Sample>> you canl sub, subtract, multiply and divide with another stream as well as with scalar value.

windowSampleStream1 + windowSampleStream2
windowSampleStream1 - windowSampleStream2
windowSampleStream1 * windowSampleStream2
windowSampleStream1 / windowSampleStream2

windowSampleStream1 + scalarValue
windowSampleStream1 - scalarValue
windowSampleStream1 * scalarValue
windowSampleStream1 / scalarValue

Arithmetic operation over two stream is a wrapper over merge operation, as limitation for merging windowed stream window should have similar characteristics. Operation with scalar is a wrapper over map operation.