An accumulator that computes the average value. Input can be {@code long}, {@code integer}, or {@code double} and the result is {@code double}.

The accumulator is used to keep a running sum and a count. The {@code getResult} method computes the average.

A simple random data generator with data rate throttling logic.

An accumulator that sums up {@code double} values.

An accumulator that finds the maximum {@code BigDecimal} value. <p>Supports numbers greater than Double.MIN_VALUE.

An accumulator that finds the minimum {@code BigDecimal} value. <p>Supports numbers less than Double.MAX_VALUE.

A test harness for testing a {@link TwoInputStreamOperator}. <p>This mock task provides the operator with a basic runtime context and allows pushing

A test harness for testing a {@link CoBroadcastWithNonKeyedOperator}. <p>This mock task provides the operator with a basic runtime context and allows

Implements main rule evaluation and alerting logic.

Implements dynamic data partitioning based on a set of broadcasted rules.

Utilities for dynamic keys extraction by field name.

Rules representation.

Rules representation.

Tests for the {@link RulesEvaluator}.

Utility to throttle a thread to a given number of executions (records) per second.

Utility to throttle a thread to a given number of executions (records) per second.