recordreader

4зной

2ответ

Hadoop MapReduce Реализация RecordReader необходима?

Из док Apache на Hadoop MapReduce InputFormat Интерфейс: "[L] ogical расщепляется на основе входного размера недостаточно для многих приложений, так как запись границы должны соблюдаться В таких случа

1зной

1ответ

Как hasoop RecordReader идентифицирует записи

При обработке текстового файла, как hasoop идентифицирует записи? Является ли он основан на символах новой строки или полных остановках? Если у меня есть список текстовых файлов из 5000 слов, все на о

0зной

2ответ

передать аргументы звукозаписывающей читателя в MapReduce Hadoop

Это мой код для использования variours ARG import java.io.File; import java.io.IOException; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.fs.FSDataInputStream; import org.

0зной

3ответ

Hadoop пользовательские записи читателя реализация

Я найти трудно понять поток, что происходит в nextKeyValue() метод, описанный в приведенной ниже ссылке: http://analyticspro.org/2012/08/01/wordcount-with-custom-record-reader-of-textinputformat/ особ

0зной

2ответ

Как преобразовать EBCDIC в TEXT с помощью Hadoop Mapreduce

Мне нужно проанализировать формат входного файла EBCDIC. Использование Java, я могу читать его, как показано ниже: InputStreamReader rdr = new InputStreamReader(new FileInputStream("/Users/rr/Document

0зной

1ответ

Hadoop 2: Пустой результат при использовании пользовательского InputFormat

Я хочу использовать собственный FileInputFormat с пользовательским RecordReader, чтобы читать данные csv в <Long><String> парах. Поэтому я создал класс MyTextInputFormat: import java.io.IOException;