Как вставить 'n' значения в гипертаблику с помощью Hadoop Python? - PullRequest
Новая
       43

Как вставить 'n' значения в гипертаблику с помощью Hadoop Python?

3 голосов
/ 07 декабря 2011

Как вставить несколько значений в гипертаблицу с использованием потоковой передачи Hadoop Python? Я могу вставить значения для одного столбца, но не более одного столбца. Пока я пытаюсь, я получаю следующее исключение: 

java.lang.RuntimeException: java.io.IOException: Unable to write cell - java.lang.Exception: incorrect output line format only 1 tabs
    at org.apache.hadoop.streaming.PipeMapRed.waitOutputThreads(PipeMapRed.java:325)
    at org.apache.hadoop.streaming.PipeMapRed.mapRedFinished(PipeMapRed.java:545)
    at org.apache.hadoop.streaming.PipeReducer.close(PipeReducer.java:137)
    at org.apache.hadoop.mapred.ReduceTask.runOldReducer(ReduceTask.java:528)
    at org.apache.hadoop.mapred.ReduceTask.run(ReduceTask.java:419)
    at org.apache.hadoop.mapred.Child$4.run(Child.java:259)
    at java.security.AccessController.doPrivileged(Native Method)
    at javax.security.auth.Subject.doAs(Subject.java:396)
    at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1059)
    at org.apache.hadoop.mapred.Child.main(Child.java:253)
Caused by: java.io.IOException: Unable to write cell - java.lang.Exception: incorrect output line format only 1 tabs
    at org.hypertable.hadoop.mapred.TextTableOutputFormat$HypertableRecordWriter.write(TextTableOutputFormat.java:247)
    at org.hypertable.hadoop.mapred.TextTableOutputFormat$HypertableRecordWriter.write(TextTableOutputFormat.java:69)
    at org.apache.hadoop.mapred.ReduceTask$OldTrackingRecordWriter.write(ReduceTask.java:456)
    at org.apache.hadoop.mapred.ReduceTask$3.collect(ReduceTask.java:496)
    at org.apache.hadoop.streaming.PipeMapRed$MROutputThread.run(PipeMapRed.java:381)

map.py 

import sys

for line in sys.stdin:
    print line

reduce.py 

import sys

for line in sys.stdin:
        txt= line.split('\t')
        print txt[0]+'\t'+txt[1]+'\t'+txt[2]

Гипертабельная форма ввода будет разделена табуляцией, пример: "это текст".

Выходная таблица содержит три столбца, мне нужно разбить входной текст по вкладкам и сохранить его в гипертабель. Гиперстабильные имена выходных столбцов cc, kw и oc.

...