Мы используем Apache Storm для предварительной обработки некоторых данных датчиков. Данные примерно такие.
Одним из наших требований является обнаружение последовательных временных рядов. например, у нас есть 4 данных, T1,T2,T3,T4, где T4-T3 больше 1 минуты, а разница между остальными меньше 1 минуты, мы считаем, что T1,T2,T3 является последовательным временем ряд, а Т4 — начало другого временного ряда.
наша топология выглядит следующим образом: носик -> болт кодека данных -> болт обнаружения временных рядов.
логика «блока кодека данных» довольно сложна, поэтому мы устанавливаем номер исполнителя равным 2. Проблема в том, что блок обнаружения временных рядов должен обрабатывать данные последовательно, но могут ли параллельные задачи «блок кодека» гарантировать это последовательность??
или мы должны реализовать это другими способами?
