Storm не читает из HDFS (HdfsSpout не распознается)

Question

Я использую шторм 1.0.x, но когда я пытаюсь использовать ниже

// Instantiate spout to read text files
        HdfsSpout textReaderSpout = newHdfsSpout().setReaderType("text")
                                                  .withOutputFields(TextFileReader.defaultFields)
                                                  .setHdfsUri("hdfs://localhost:54310")  // reqd
                                                  .setSourceDir("/data/in")              // reqd
                                                  .setArchiveDir("/data/done")           // reqd
                                                  .setBadFilesDir("/data/badfiles");     // required

Я получаю HdfsSpout cannot be resolved to a type

доступна ли эта функция в определенных версиях или в чем может быть проблема?

Answer 1

Я полагаю, у вас нет штормовых hdf на пути к классам. Проверьте ваш pom (или эквивалент для любой используемой вами системы управления зависимостями) и убедитесь, что storm-hdfs объявлен как зависимость.