You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2015/05/11 23:48:52 UTC
svn commit: r1678828 -
/pig/branches/branch-0.15/test/e2e/pig/tests/streaming.conf
Author: daijy
Date: Mon May 11 21:48:51 2015
New Revision: 1678828
URL: http://svn.apache.org/r1678828
Log:
PIG-4532: Pig Documentation contains typo for AvroStorage (Revert unintended changes)
Modified:
pig/branches/branch-0.15/test/e2e/pig/tests/streaming.conf
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=1678828&r1=1678827&r2=1678828&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:48:51 2015
@@ -39,14 +39,13 @@ $cfg = {
'num' => 1,
'pig' => q#
A = load ':INPATH:/singlefile/studenttab10k';
-B = foreach A generate $2, $1;
-C = stream B through `awk 'BEGIN {FS = "\t"; OFS = "\t"} {print $2, $1}'`;
+B = foreach A generate $2, $1, $0;
+C = stream B through `awk 'BEGIN {FS = "\t"; OFS = "\t"} {print $3, $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;
-C = stream B through CMD;
+B = foreach A generate $2, $1, $0;
+C = stream B through `awk "BEGIN {FS = \\\\"\t\\\\"; OFS = \\\\"\t\\\\"} {print $3, $2, $1}"`;
store C into ':OUTPATH:';#,
'sql' => "select name, age, gpa from studenttab10k;",
},
@@ -55,15 +54,16 @@ store C into ':OUTPATH:';#,
'num' => 2,
'pig' => q#
A = load ':INPATH:/singlefile/studenttab10k';
-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:';#,
+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:';#,
'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;
-C = stream B through CMD as (age, gpa);
-store C into ':OUTPATH:';#,
+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:';#,
'sql' => "select name, age from studenttab10k;",
},
{