GeoMesa ничего не делает для синхронизации индексов - как правило, об этом нужно позаботиться в вашем конвейере загрузки.
Если у вас есть надежный идентификатор функции, связанный с данной функцией ввода, вы можете написать эту функциюнесколько раз, не вызывая дубликатов.Если во время загрузки пакета функций происходит сбой из-за временной проблемы, вы можете просто переписать их, чтобы убедиться в правильности индексов.
Для HBase, когда вы вызываете flush или closeв конструкторе объектов ожидающие мутации будут отправлены в кластер.После успешного возврата этого метода данные сохраняются в HBase.Если выдается исключение, вам следует повторить попытку неисправных функций.При последующих сбоях HBase может потребоваться восстановление журналов опережающей записи (WAL) в соответствии со стандартной операцией HBase.
Функция также может не записываться из-за проверки (например, нулевая геометрия).В этом случае вы не захотите повторно использовать эту функцию, поскольку она никогда не будет успешно принята.Если вы используете инфраструктуру конвертера GeoMesa, вы можете предварительно проверить функции , чтобы убедиться, что они будут нормально работать.
Если у вас еще нет конвейера загрузки, вы можете проверитьout geomesa-nifi , что позволит вам преобразовывать и проверять входные данные и автоматически повторять попытки сбоев через потоки Nifi.