Я пытаюсь отобразить текущую позицию каждого устройства, зарегистрированного в моей базе данных geomesa-accumulo, через WPS геосервера. Поскольку каждое устройство отправляет свою позицию каждые X секунд. Я использую процесс TrackLabel геомесы, чтобы получить последнюю позицию каждого устройства, настройка процесса WPS:
track: device_id
dtg : date_time
С помощью я запускаю процесс и отображаю результаты с помощью листовки. Но я думаю, что результаты не такие, как я ожидал, потому что если я выполню следующий запрос в блокноте jupyter:
spark.sql("select device_id, date_time, position from positions where device_id = 145 order by date_time desc limit 1").show()
Он возвращает, что последняя позиция была 2016-05-17 20:47, но процесс TrackLabel говорит 2016-03-05 20:12.
Мои вопросы: если это правильный подход, то чего мне не хватает? Или каким должен быть правильный подход к этой проблеме?
geomesa export ... --attributes date_time -q "device_id = 'foo'" | sort -r | head -n1
- person Emilio Lahr-Vivaz   schedule 26.09.2017