Как использовать camelCase при импорте sqoop - PullRequest
Новая
       4

Как использовать camelCase при импорте sqoop

0 голосов
/ 09 октября 2018

Я делаю импорт sqoop из postgresql в hdfs.Команда sqoop: 

    sqoop import  -D org.apache.sqoop.splitter.allow_text_splitter=true 
    -D mapreduce.output.basename=customer  
    --connect jdbc:postgresql://************* 
    --username **********   --password *****
    --map-column-java content=String --query "select id,updated,
    (select row_to_json(results) from (select (content ->>'id')::text as 
    "id",(content ->>'managingOrganization')::json as "managingOrganization" 
     from customer pa1 where pa1.version_id=customer.id) as results)as 
     content from customer  where \$CONDITIONS" --fields-terminated-by '|'
    --split-by updated  --incremental updated  --check-column updated 
    --merge-key id  --target-dir /home/customer -m 4 
    --input-null-string  '\\N'  --input-null-non-string '\\N'

Команда sqoop работает нормально, за исключением того, что одна вещь, управляющая организацией, сохраняется как управляющая организация в моей HDFS.Как убедиться, что данные сохранены, используя верблюжий чехол.Когда я запускаю команду select query в postgresql, она становится идеальной, и результат находится в camelcase.Но при использовании sqoop он меняется. Предлагает что-то.

...