Скажем, у меня есть два потока: Stream 1: [1,3],[2,4] Stream 2: [2,5],[3,2] Обычное слияние создаст поток 3, например: [1,3],[2,4],[2,5],[3,2] Я хотел бы объединить поток, сохраняя порядок, в котором кортеж был выпущен, поэтому, если...

У меня есть строки в БД BigData (в моем случае Cassandra) с именами столбцов col1, col2, col3, val1, val2 в подходе SQL я могу группировать по col1, col2 или col2, col1 или любым другим возможным способом. Таким образом, я могу легко сформировать...

Я изучаю, как использовать Storm's Trident с Cassandra 2.0.5, Storm версии 0.9.0.1. Я также использую com.hmsonline storm-cassandra 0.4.0-rc4 contrib. Моя цель - просто вставить несколько текстовых строк в таблицу со столбцами идентификатора...

Чтобы применить некоторую функцию к потоку в Trident Storm, мы передаем вновь созданный экземпляр методу each , который вызывается в потоке следующим образом: stream.each(inputFields, new SomeFunc(), outputFields) где SomeFunc — потомок...

У меня есть топология, которая получает данные от брокера MQTT, и я хочу, чтобы носик вел себя следующим образом: Выдавать пакет кортежей (или список строк в одном кортеже) каждые x секунд. Как мне этого добиться? Я немного читал о Storm...

Может ли кто-нибудь пролить свет на то, как записывать/читать данные из трезубцевого шторма в сетку памяти (зажигание Apache). Я гуглил и не нашел никакой информации/документа о том, как подключиться от Trident Storm к сетке памяти.

Мы используем Kafka-storm в нашем проекте. В шторм мы будем использовать несколько болтов для трансформаций. Но перед этим, как часть POC, мы хотим сохранить данные в БД. Какой фреймворк нам следует использовать? Для сценария BigData, который...

Я перехожу от традиционной топологии Storm к топологии Trident, которая поддерживает пакеты кортежей перед их отправкой в ​​базу данных. Мы обрабатываем XML-файлы как один кортеж. В традиционной топологии, которая обрабатывает один xml за раз, это...

Я создаю топо для получения сообщений от kafka, а затем grep какое-то ключевое слово, если оно подходит, записываю в локальный файл. Я использую OpaqueTridentKafkaSpout storm-kafka, чтобы кортеж не пропустил и не повторился, но рассмотрим одну...

Я читаю данные из 2 тем кафки. Что можно описать как: Topic1 data content: VehicleRegistrationNo, Timestamp, Location Topic2 data content: VehicleRegistrationNo, Timestamp, Speed Мне нужно объединить эти 2 сообщения на основе ближайшей метки...