apache-samza

0зной

1ответ

Как развернуть и запустить работу Samza на HDFS?

Я хочу, чтобы работа Samza работала на удаленной системе с заданием Samza, хранящимся на HDFS. Пример (https://samza.apache.org/startup/hello-samza/0.7.0/) для запуска работы Samza на угольной машине

0зной

1ответ

Правила агрегирования Apache Storm для отсутствия ожидаемых событий в скользящем периоде времени

Мой прецедент предназначен для идентификации объектов, из которых ожидаемые события не были получены после X времени в режиме реального времени, а не с использованием пакетных заданий. Например: Если

0зной

1ответ

Правила агрегации Apache Samza для отсутствия ожидаемых событий в период времени проката

Мой прецедент предназначен для идентификации объектов, из которых ожидаемые события не были получены после X количества времени в реальном времени. Например: Если мы получили событие PaymentInitiated

0зной

1ответ

Требуется ли Samza OutgoingMessageEnvelope для SerDe для partitionKey и как его указать?

Как и для how-can-you-create-a-partition-on-a-kafka-topic-using-samza Мне нужно создать сообщение, контролирующее, как оно маршрутизируется с помощью partitionKey. ключ и сообщение требуют SerDe, но я

1зной

1ответ

Приложения для приложений Storm

Я создал приложение для поиска похожих хранилищ изображений в распределенной среде с использованием Hadoop. Но Hadoop не поддерживает обработку в реальном времени, поэтому время ответа длительное. Я з