Как использовать сгенерированный класс sqoop в MapReduce?

Запрос sqoop генерирует файл Java, содержащий класс, содержащий код для получения доступа в mapreduce к данным столбцов для каждой строки. (Импорт Sqoop выполнялся в текстовом виде без параметра --as -sequencefile, с 1 строкой на запись и запятыми между столбцами )Но как мы на самом деле его используем?

Я нашел публичный метод parse ()в этом классе, который принимает текст в качестве входных данных и заполняет все члены класса, поэтому для практики я изменил приложение подсчета слов, чтобы преобразовать строку текста из TextInputFormat в преобразователе в экземпляр класса, сгенерированного sqoop. Но это вызывает «незарегистрированное исключение.com.cloudera.sqoop.lib.RecordParser.ParseError; должно быть перехвачено или объявлено для выдачи», когда я вызываю метод parse ().

Можно ли это сделать таким образом, или для заполнения класса данными из каждой записи необходим пользовательский InputFormat?

5
задан bill ou 19 July 2012 в 16:20
поделиться