Hadoop для ввода данных в маппере внутри программы, а не из файлов

Question

Я пытаюсь не использовать файлы в качестве входных данных в Hadoop.У меня есть Java-программа, и она выдает выходные данные, такие как 'chicken', '10', и я храню их в массивах, и я хочу, чтобы эта запись напрямую передавалась в класс Mapper.У кого-нибудь есть идея, как подать такой ввод напрямую в Hadoop и не использовать файлы в качестве ввода?Большое спасибо

Answer 1

Вы должны использовать свой собственный класс, который расширяет InputFormat<K,V> и указать вашей работе hadoop использовать этот класс вместо FileInputFormat.См. документацию здесь.