Author: daijy
Date: Mon May 11 21:46:46 2015
New Revision: 1678827
URL: http://svn.apache.org/r1678827
Log:
PIG-4532: Pig Documentation contains typo for AvroStorage
Modified:
pig/branches/branch-0.15/CHANGES.txt
pig/branches/branch-0.15/src/docs/src/documentation/content/xdocs/func.xml
pig/branches/branch-0.15/test/e2e/pig/tests/streaming.conf
Modified: pig/branches/branch-0.15/CHANGES.txt
URL:
http://svn.apache.org/viewvc/pig/branches/branch-0.15/CHANGES.txt?rev=1678827&r1=1678826&r2=1678827&view=diff
==============================================================================
--- pig/branches/branch-0.15/CHANGES.txt (original)
+++ pig/branches/branch-0.15/CHANGES.txt Mon May 11 21:46:46 2015
@@ -66,6 +66,8 @@ PIG-4333: Split BigData tests into multi
BUG FIXES
+PIG-4532: Pig Documentation contains typo for AvroStorage
(fredericschmaljohann via daijy)
+
PIG-4377: Skewed outer join produce wrong result in some cases (daijy)
PIG-4538: Pig script fail with CNF in follow up MR job (daijy)
Modified:
pig/branches/branch-0.15/src/docs/src/documentation/content/xdocs/func.xml
URL:
http://svn.apache.org/viewvc/pig/branches/branch-0.15/src/docs/src/documentation/content/xdocs/func.xml?rev=1678827&r1=1678826&r2=1678827&view=diff
==============================================================================
--- pig/branches/branch-0.15/src/docs/src/documentation/content/xdocs/func.xml
(original)
+++ pig/branches/branch-0.15/src/docs/src/documentation/content/xdocs/func.xml
Mon May 11 21:46:46 2015
@@ -1942,7 +1942,7 @@ STORE A INTO 'hbase://users_table' USING
<table>
<tr>
<td>
- <p>Avrostorage(['schema|record name'], ['options'])</p>
+ <p>AvroStorage(['schema|record name'], ['options'])</p>
</td>
</tr>
</table>
Modified: pig/branches/branch-0.15/test/e2e/pig/tests/streaming.conf
URL:
http://svn.apache.org/viewvc/pig/branches/branch-0.15/test/e2e/pig/tests/streaming.conf?rev=1678827&r1=1678826&r2=1678827&view=diff
==============================================================================
--- pig/branches/branch-0.15/test/e2e/pig/tests/streaming.conf (original)
+++ pig/branches/branch-0.15/test/e2e/pig/tests/streaming.conf Mon May 11
21:46:46 2015
@@ -39,13 +39,14 @@ $cfg = {
'num' => 1,
'pig' => q#
A = load ':INPATH:/singlefile/studenttab10k';
-B = foreach A generate $2, $1, $0;
-C = stream B through `awk 'BEGIN {FS = "\t"; OFS = "\t"} {print $3, $2, $1}'`;
+B = foreach A generate $2, $1;
+C = stream B through `awk 'BEGIN {FS = "\t"; OFS = "\t"} {print $2, $1}'`;
store C into ':OUTPATH:';#,
'pig_win' => q#
+DEFINE CMD `awk -F "\\\t" "{print $2, $1}"` output(stdout using PigStreaming('
'));
A = load ':INPATH:/singlefile/studenttab10k';
-B = foreach A generate $2, $1, $0;
-C = stream B through `awk "BEGIN {FS = \\\\"\t\\\\"; OFS = \\\\"\t\\\\"}
{print $3, $2, $1}"`;
+B = foreach A generate $2, $1;
+C = stream B through CMD;
store C into ':OUTPATH:';#,
'sql' => "select name, age, gpa from studenttab10k;",
},
@@ -54,16 +55,15 @@ store C into ':OUTPATH:';#,
'num' => 2,
'pig' => q#
A = load ':INPATH:/singlefile/studenttab10k';
-B = foreach A generate $2, $1, $0;
-C = stream B through `awk 'BEGIN {FS = "\t"; OFS = "\t"} {print $3, $2, $1}'`
as (name, age, gpa);
-D = foreach C generate name, age;
-store D into ':OUTPATH:';#,
+B = foreach A generate $2, $1;
+C = stream B through `awk 'BEGIN {FS = "\t"; OFS = "\t"} {print $2, $1}'` as
(name, age);
+store C into ':OUTPATH:';#,
'pig_win' => q#
+DEFINE CMD `awk -F "\\\t" "{print $2, $1}"` output(stdout using PigStreaming('
'));
A = load ':INPATH:/singlefile/studenttab10k';
-B = foreach A generate $2, $1, $0;
-C = stream B through `awk "BEGIN {FS = \\\\"\t\\\\"; OFS = \\\\"\t\\\\"}
{print $3, $2, $1}"` as (name, age, gpa);
-D = foreach C generate name, age;
-store D into ':OUTPATH:';#,
+B = foreach A generate $2, $1;
+C = stream B through CMD as (age, gpa);
+store C into ':OUTPATH:';#,
'sql' => "select name, age from studenttab10k;",
},
{
