Мы работаем над модулем po c, предназначенным для анализа продаж и выявления мошенничества. Технология, которую мы хотим использовать: аналитика потокового процессора wso2 с базой данных oracle. Сначала мы представляем, что можно было получать данные и постоянно анализировать их. Проблема, с которой мы сталкиваемся, заключается в том, что клиент говорит нам, что когда-нибудь в потоке могут появиться плохие данные, поэтому их необходимо исправить после того, как они были приняты и использованы, и снова проанализировать ... Я не знаю, является ли это даже можно сделать это.
Итак, мой вопрос: существует ли какое-либо шаблонное или традиционное потоковое решение для обработки того факта, что те же данные могут быть проанализированы снова после исправления оператором?