You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by zl...@apache.org on 2017/04/19 01:52:39 UTC
svn commit: r1791846 -
/pig/branches/spark/test/org/apache/pig/spark/TestSparkCompiler.java
Author: zly
Date: Wed Apr 19 01:52:39 2017
New Revision: 1791846
URL: http://svn.apache.org/viewvc?rev=1791846&view=rev
Log:
PIG-5202:Create a TestSparkCompiler test class for spark branch-2(Adam via Liyun)
Modified:
pig/branches/spark/test/org/apache/pig/spark/TestSparkCompiler.java
Modified: pig/branches/spark/test/org/apache/pig/spark/TestSparkCompiler.java
URL: http://svn.apache.org/viewvc/pig/branches/spark/test/org/apache/pig/spark/TestSparkCompiler.java?rev=1791846&r1=1791845&r2=1791846&view=diff
==============================================================================
--- pig/branches/spark/test/org/apache/pig/spark/TestSparkCompiler.java (original)
+++ pig/branches/spark/test/org/apache/pig/spark/TestSparkCompiler.java Wed Apr 19 01:52:39 2017
@@ -74,8 +74,9 @@ public class TestSparkCompiler {
public void doPrint(PrintStream ps, SparkOperPlan plan) throws VisitorException, ParserConfigurationException, TransformerException {
switch (this) {
case DOT:
- (new DotSparkPrinter(plan, ps)).dump();
- break;
+ throw new RuntimeException("Testing in DOT format not supported yet");
+ //(new DotSparkPrinter(plan, ps)).dump();
+ //break;
case XML:
XMLSparkPrinter printer = new XMLSparkPrinter(ps, plan);
printer.visit();
@@ -134,7 +135,8 @@ public class TestSparkCompiler {
run(query, "test/org/apache/pig/test/data/GoldenFiles/spark/SPARKC-LoadStore-1-text.gld", PlanPrinter.TEXT);
run(query, "test/org/apache/pig/test/data/GoldenFiles/spark/SPARKC-LoadStore-1-xml.gld", PlanPrinter.XML);
- run(query, "test/org/apache/pig/test/data/GoldenFiles/spark/SPARKC-LoadStore-1-dot.gld", PlanPrinter.DOT);
+ //TODO: enable this when DOT file comparison is supported
+ //run(query, "test/org/apache/pig/test/data/GoldenFiles/spark/SPARKC-LoadStore-1-dot.gld", PlanPrinter.DOT);
}
private void run(String query, String expectedFile, PlanPrinter planPrinter) throws Exception {