Hadoop Pig Присоединиться к данным из Hbase

Question

Я пытаюсь присоединиться к данным из текстового файла с данными из hbase, но не удалось.

Вот данные, которые я использовал.

1. С: (XXX1,06820,7) (XXX2,07442,9)
2. G1: (XXX1,53) (XXX2,54)
3. G2: (XXX1,53) (XXX1,53)

G1 - это загрузка из текстового файла, а G2 загружается из HBase.

• G1: {зп: ByteArray, страна: chararray}
• G2: {зп: ByteArray, страна: chararray}
• J1 = Регистрация C по зп, G1 по зп
• J2 = Регистрация C через sn, G2 - sn.

Когда дамп J1, я могу получить результат, но для J2 я ничего не получил и вот журнал.

Successfully read records from: "/opt/inputdata/ips1" 
Successfully read records from: "hbase://geoinfo1" 

Output(s): 
Successfully stored records in: "file:/tmp/temp410352744/tmp-403556508" -- EMPTY FILE 

Successfully read 616 records (11473 bytes) from: "/opt/inputdata/ips1" 
Successfully read 1354204 records from: "hbase://geoinfo" 

Output(s): 
Successfully stored 0 records in: "hdfs://master:9000/user/hadoop/jjj" --- EMPTY FILE 

Есть ли что-то не так с моим решением? Что делать, если я хочу загрузить данные из hbase и присоединиться к данным из текстовых файлов?

Заранее спасибо.

Answer 1

Я предполагаю, что вы загрузили данные в Hbase Затем используйте следующий сценарий свинью на хрюкать оболочки подскажете

Сценарий свинью для хранения с HBaseStorage:

G1 = НАГРУЗКИ «HBase: // geoinfo1 'USING org.apache.pig.backend.hadoop.hbase.HBaseStorage (' column_family_name: * ',' -loadKey true -gt 10000 ') AS (sn: chararray, country: chararray);