2016-03-25 25 views
0

我試圖從豬列刪除字符:\ n,\ t和\ r但我得到錯誤的輸出。豬 - 刪除換行符,退回和選項卡

下面是我在做什麼:

qr_1 = LOAD 'hdfs://localhost:9000/sample.csv' USING PigStorage(',') as (Id:int,PostTypeId:int,AcceptedAnswerId:int,ParentId:int,CreationDate:chararray,DeletionDate:chararray,Score:int,ViewCount:int,Body:chararray,OwnerUserId:int,OwnerDisplayName:chararray,LastEditorUserId:int,LastEditorDisplayName:chararray,LastEditDate:chararray,LastActivityDate:chararray,Title:chararray,Tags:chararray,AnswerCount:int,CommentCount:int,FavoriteCount:int,ClosedDate:chararray,CommunityOwnedDate:chararray); 
qr_1 = FOREACH qr_1 GENERATE Id .. ViewCount, REPLACE(Body,'\n','') as Body, OwnerUserId .. ; 
qr_1 = FOREACH qr_1 GENERATE Id .. ViewCount, REPLACE(Body,'\r','') as Body, OwnerUserId .. ; 
qr_1 = FOREACH qr_1 GENERATE Id .. ViewCount, REPLACE(Body,'\t','') as Body, OwnerUserId .. ; 

輸入:

5585779,1,5585800,,2011-04-07 18:27:54,,1432,3090250,"<p>How can I convert a <code>String</code> to an <code>int</code> in Java?</p> 

<p>My String contains only numbers and I want to return the number it represents.</p> 

<p>For example, given the string <code>""""1234""""</code> the result should be the number <code>1234</code>.</p>",537967,,2756409,user166390,2015-09-10 21:30:42,2016-03-07 00:42:49,Converting String to Int in Java?,<java><string><type-conversion>,12,0,239 

輸出:

(5585779,1,5585800,,2011-04-07 18:27:54,,1432,3090250,"<p>How can I convert a <code>String</code> to an <code>int</code> in Java?</p>,,,,,,,,,,,,,) 
(,,,,,,,,,,,,,,,,,,,,,) 
(,,,,,,,,,,,,,,,,,,,,) 
(,,,,,,,,,,,,,,,,,,,,,) 
(,,537967,,2756409,user166390,,,Converting String to Int in Java?,,12,0,239,,,,,,,,,) 

我在做什麼?

感謝。

另外「\\ n」沒有區別。

+1

爲什麼你不能先按行讀取數據,然後再按逗號分隔? –

+0

@ cricket_007因爲正文列包含換行符。 –

+0

難道你的身體列中包含逗號? –

回答

2

數據中包含逗號,這就是字段和模式不匹配的原因。使用CSVLoader,然後使用REPLACE命令替換'\\ t','\\ n','\\ r'

<p>For example, given the string