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 2010/10/22 03:22:44 UTC
svn commit: r1026192 -
/pig/trunk/test/org/apache/pig/test/TestPruneColumn.java
Author: daijy
Date: Fri Oct 22 01:22:44 2010
New Revision: 1026192
URL: http://svn.apache.org/viewvc?rev=1026192&view=rev
Log:
Cleanup some dead code in TestPruneColumn
Modified:
pig/trunk/test/org/apache/pig/test/TestPruneColumn.java
Modified: pig/trunk/test/org/apache/pig/test/TestPruneColumn.java
URL: http://svn.apache.org/viewvc/pig/trunk/test/org/apache/pig/test/TestPruneColumn.java?rev=1026192&r1=1026191&r2=1026192&view=diff
==============================================================================
--- pig/trunk/test/org/apache/pig/test/TestPruneColumn.java (original)
+++ pig/trunk/test/org/apache/pig/test/TestPruneColumn.java Fri Oct 22 01:22:44 2010
@@ -38,10 +38,8 @@ import org.apache.log4j.SimpleLayout;
import org.apache.pig.ExecType;
import org.apache.pig.FilterFunc;
import org.apache.pig.PigServer;
-import org.apache.pig.builtin.PigStorage;
import org.apache.pig.data.Tuple;
import org.apache.pig.impl.io.FileLocalizer;
-import org.apache.pig.impl.logicalLayer.FrontendException;
import org.apache.pig.newplan.logical.rules.ColumnPruneVisitor;
import org.junit.After;
import org.junit.Before;
@@ -63,23 +61,6 @@ public class TestPruneColumn extends Tes
File tmpFile10;
File logFile;
- static public class PigStorageWithTrace extends PigStorage {
-
- /**
- * @param delimiter
- */
- public PigStorageWithTrace() {
- super();
- }
- @Override
- public RequiredFieldResponse pushProjection(RequiredFieldList requiredFieldList) throws FrontendException {
- RequiredFieldResponse response = super.pushProjection(requiredFieldList);
- Logger logger = Logger.getLogger(this.getClass());
- logger.info(requiredFieldList);
- return response;
- }
-
- }
private static final String simpleEchoStreamingCommand;
static {
if (System.getProperty("os.name").toUpperCase().startsWith("WINDOWS"))
@@ -107,10 +88,6 @@ public class TestPruneColumn extends Tes
FileAppender appender = new FileAppender(layout, logFile.toString(), false, false, 0);
logger.addAppender(appender);
- Logger pigStorageWithTraceLogger = Logger.getLogger(PigStorageWithTrace.class);
- pigStorageWithTraceLogger.setLevel(Level.INFO);
- pigStorageWithTraceLogger.addAppender(appender);
-
pigServer = new PigServer("local");
//pigServer = new PigServer(ExecType.MAPREDUCE, cluster.getProperties());
tmpFile1 = File.createTempFile("prune", "txt");
@@ -1820,8 +1797,7 @@ public class TestPruneColumn extends Tes
// See PIG-1210
@Test
public void testFieldsToReadDuplicatedEntry() throws Exception {
- pigServer.registerQuery("A = load '"+ Util.generateURI(tmpFile1.toString(), pigServer.getPigContext()) + "' using "+PigStorageWithTrace.class.getName()
- +" AS (a0, a1, a2);");
+ pigServer.registerQuery("A = load '"+ Util.generateURI(tmpFile1.toString(), pigServer.getPigContext()) + "' AS (a0, a1, a2);");
pigServer.registerQuery("B = foreach A generate a0+a0, a1, a2;");
Iterator<Tuple> iter = pigServer.openIterator("B");