我正在测试一个支持连续查询的数据流系统的性能。
它是这样工作的: - 有一个轮询服务将数据发送到我的系统。 - 当数据进入系统时,每个查询都基于当前时间的数据流窗口进行评估。 - 随着数据的传递,窗口滑动。
我的问题是,当我向系统添加更多查询时,我应该预期吞吐量会减少,因为它无法处理数据速率。
然而,实际上我观察到了吞吐量的增加。
我不明白为什么会出现这种情况,我猜测这可能与JVM分配CPU、内存等方面有关。
有人能解决我的问题吗?
它是这样工作的: - 有一个轮询服务将数据发送到我的系统。 - 当数据进入系统时,每个查询都基于当前时间的数据流窗口进行评估。 - 随着数据的传递,窗口滑动。
我的问题是,当我向系统添加更多查询时,我应该预期吞吐量会减少,因为它无法处理数据速率。
然而,实际上我观察到了吞吐量的增加。
我不明白为什么会出现这种情况,我猜测这可能与JVM分配CPU、内存等方面有关。
有人能解决我的问题吗?