使用 Esper + Twitter4J 检查数据

Question

我正在使用 Esper 和 Twitter4J 来处理来自 Twitterstream 的数据。现在我想将当前数据与过去 10 秒的所有数据进行比较。我想检查是否有人在 10 秒的时间片内发布了两条或更多条推文。这种支票的声明是什么？还是在 Esper 声明之外检查这些？

我现在的声明是：

String expression = "select user, sum(ctr) from Tweet.win:time(10 seconds) having user IN (select user from Tweet.win:time(10 seconds))";

我知道这是错误的，因为正在比较两个相同的变量，但我不知道如何检查，如果同一用户在最后 10 秒内被发现...

感谢任何帮助。

Answer 1

我想出来了，一定是：

select user, count(user), text from Tweet.win:time(1sec) group by user having (count(user) > 1)

Check Data with Esper + Twitter4J