Как написать болт HDFS для Twitter Streaming с помощью Шторма

Question

Как записать данные из штормового потока в HDFS Я имею в виду, чтобы добавить в код TweetTopology.java lesson2 - Ступень 5. - (Twitterfeed нужно хранить в HDFS)

Можете ли вы помочь написать hdfs болт здесь.

Answer 1

Посмотрите HdfsBolt, уже реализованы: https://github.com/ptgoetz/storm-hdfs/blob/master/src/main/java/org/apache/storm/hdfs/bolt/HdfsBolt.java

Все, что вам нужно сделать, это установить его с соответствующим/желаемой конфигурации и записывает данные в HDFS.