flume

0зной

2ответ

HDFS раковина: «умная» маршрутизация папки

Я новичок в Flume (и HDFS), поэтому надеюсь, что мой вопрос не глуп. У меня есть многопользовательская заявка (около 100 различных клиентов, как для ). У меня есть 16 различных типов данных. (В произв

0зной

1ответ

перенаправить JMS-сообщения на основе свойства в сообщении с использованием флюма

Мы настроили Flume для чтения сообщений JMS из системы, и это работает нормально. Теперь я хотел бы прочитать сообщение и перенаправить его в несколько местоположений на основе свойства в сообщении. П

-4зной

1ответ

Загрузка определенных твитов по стране с использованием Flume

Я хочу загрузить определенные твиты из источника Twitter в HDFS с использованием Flume, например. tweets.country = US. Как можно настроить Flume для этого?

0зной

2ответ

Flume: org.apache.avro.ipc.NettyServer: Неожиданное исключение из нисходящего потока. java.nio.channels.ClosedChannelException

Как решить проблему? Когда я настраиваю сервер flume, у него были следующие квесты. 2014-10-20 22:24:01,480 INFO org.apache.avro.ipc.NettyServer: [id: 0x2fe09f1a, /ip:57063 => /ip:34001] OPEN 2014-10

-2зной

2ответ

Как получать твиты в реальном времени с использованием лотка?

Apache flume извлекает твиты прошлых лет или месяцев, а также с моей текущей конфигурацией. Я хочу получить текущие твиты. Как я могу это сделать?

0зной

1ответ

Как замедлить генератор последовательности потоков

У потока есть источник, называемый Sequence Generator, который может быть использован для тестирования; он просто генерирует случайные данные (увеличивающиеся числа). Я использую его для тестирования/

-1зной

2ответ

Twitter API поиска и Hadoop

Мне нужно использовать API поиска в Twitter и получать данные Twitter в мою HDFS. API поиска использует вызовы REST, и я пытаюсь понять, как я буду использовать это с Apache Flume. У меня есть ключи д

0зной

1ответ

Форматирование Apache Flume HDFS Serializer

Я только начинаю с флюма и должен вставлять некоторые заголовки в раковину hdfs. У меня это работает, хотя формат неправильный, и я не могу управлять столбцами. Используя эту конфигурацию: a1.sources