Поиск актуальных тем из потока данных

Question

Найти тренд для одного слова очень просто: вы можете разбить каждое слово на поток данных, выполнить подсчет и ограничить его за последние 24 часа или 48 часов. Я не уверен, как найти тренды из двух или трех словосочетаний? Любая помощь оценена

Answer 1

Итак, у вас есть кое-что - для случая с одним словом - которое говорит что-то вроде:

while (true)
    word = readNextWord()
    register(word, now)
    discardWordsOlderThan (now - windowSize)

Просто следите за предыдущим словом:

while (true)
    word = readNextWord()
    register(prev + " " + word, now)
    prev = word
    discardWordsOlderThan (now - windowSize)