pig-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From s..@apache.org
Subject svn commit: r1364197 - in /pig/trunk: ./ contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/ contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/ contrib/piggybank/java/src/test/java/org/apache/pig/pi...
Date Sun, 22 Jul 2012 00:30:46 GMT
Author: sms
Date: Sun Jul 22 00:30:45 2012
New Revision: 1364197

URL: http://svn.apache.org/viewvc?rev=1364197&view=rev
Log:
PIG-2492: AvroStorage should recognize globs and commas (cheolsoo via sms)

Added:
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/expected_testDir.avro
  (with props)
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/expected_test_dir_1.avro
  (with props)
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/expected_test_dir_1_2.avro
  (with props)
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_glob1.avro
  (with props)
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_glob2.avro
  (with props)
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_glob3.avro
  (with props)
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_subdir/
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_subdir/test_glob4.avro
  (with props)
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_subdir/test_glob5.avro
  (with props)
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir2/
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir2/test_glob4.avro
  (with props)
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir2/test_glob5.avro
  (with props)
Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroStorage.java
    pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroStorageUtils.java
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/TestAvroStorage.java
    pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/TestAvroStorageUtils.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1364197&r1=1364196&r2=1364197&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Sun Jul 22 00:30:45 2012
@@ -24,6 +24,8 @@ INCOMPATIBLE CHANGES
 
 IMPROVEMENTS
 
+PIG-2492: AvroStorage should recognize globs and commas (cheolsoo via sms)
+
 PIG-2706: Add clear to list of grunt commands (xalan via azaroth)
 
 PIG-2823: TestPigContext.testImportList() does not pass if another javac in on the PATH (julien)

Modified: pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroStorage.java
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroStorage.java?rev=1364197&r1=1364196&r2=1364197&view=diff
==============================================================================
--- pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroStorage.java
(original)
+++ pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroStorage.java
Sun Jul 22 00:30:45 2012
@@ -131,17 +131,24 @@ public class AvroStorage extends FileInp
      */
     @Override
     public void setLocation(String location, Job job) throws IOException {
-        HashSet<Path> paths = new HashSet<Path>();
-        if(AvroStorageUtils.getAllSubDirs(URI.create(location), job, paths) && inputAvroSchema
== null) {
+        if (inputAvroSchema != null) {
+            return;
+        }
+        Set<Path> paths = new HashSet<Path>();
+        if (AvroStorageUtils.getAllSubDirs(new Path(location), job, paths)) {
             FileInputFormat.setInputPaths(job, paths.toArray(new Path[0]));
             inputAvroSchema = getAvroSchema(location, job);
+        } else {
+            throw new IOException("Input path \'" + location + "\' is not found");
         }
     }
 
     protected Schema getAvroSchema(String location, Job job) throws IOException {
-        Configuration conf = job.getConfiguration();
-        FileSystem fs = FileSystem.get(URI.create(location), conf);
-        Path path = new Path(location);
+        Path path = AvroStorageUtils.getConcretePathFromGlob(location, job);
+        if (path == null) {
+            return null;
+        }
+        FileSystem fs = FileSystem.get(path.toUri(), job.getConfiguration());
         return getAvroSchema(path, fs);
     }
 

Modified: pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroStorageUtils.java
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroStorageUtils.java?rev=1364197&r1=1364196&r2=1364197&view=diff
==============================================================================
--- pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroStorageUtils.java
(original)
+++ pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/avro/AvroStorageUtils.java
Sun Jul 22 00:30:45 2012
@@ -101,7 +101,7 @@ public class AvroStorageUtils {
       Configuration conf = job.getConfiguration();
       FileSystem fs = FileSystem.get(conf);
       HashSet<Path> paths = new  HashSet<Path>();
-      if (getAllSubDirs(URI.create(pathString), job, paths))
+      if (getAllSubDirs(new Path(pathString), job, paths))
       {
         paths.addAll(Arrays.asList(FileInputFormat.getInputPaths(job)));
         FileInputFormat.setInputPaths(job, paths.toArray(new Path[0]));
@@ -116,30 +116,40 @@ public class AvroStorageUtils {
      * 
      * @throws IOException
      */
-    static boolean getAllSubDirs(URI location, Job job, Set<Path> paths) throws IOException
{
-        FileSystem fs = FileSystem.get(location, job.getConfiguration());
-        Path path = new Path(location.getPath());
-  		if (PATH_FILTER.accept(path)) {
-  			try {
-  				FileStatus file = fs.getFileStatus(path);
-  				if (file.isDir()) {
-  					for (FileStatus sub : fs.listStatus(path)) {
-                        getAllSubDirs(sub.getPath().toUri(), job, paths);
-  					}
-  				} else {
-  					AvroStorageLog.details("Add input file:" + file);
-  					paths.add(file.getPath());
-  				}
-  			} catch (FileNotFoundException e) {
-                AvroStorageLog.details("getAllSubDirs: RETURN FALSE; Input path does not
exist: " + path);
-  				AvroStorageLog.details("Input path does not exist: " + path);
-  				return false;
-  			}
-  			return true;
-  		}
-  		return false;
-  	}
-     
+    static boolean getAllSubDirs(Path path, Job job, Set<Path> paths) throws IOException
{
+        FileSystem fs = FileSystem.get(path.toUri(), job.getConfiguration());
+        FileStatus[] matchedFiles = fs.globStatus(path, PATH_FILTER);
+        if (matchedFiles == null || matchedFiles.length == 0) {
+            return false;
+        }
+        for (FileStatus file : matchedFiles) {
+            if (file.isDir()) {
+                for (FileStatus sub : fs.listStatus(path)) {
+                    getAllSubDirs(sub.getPath(), job, paths);
+                }
+            } else {
+                AvroStorageLog.details("Add input file:" + file);
+                paths.add(file.getPath());
+            }
+        }
+        return true;
+    }
+
+    /**
+     * Return the first path that matches the glob pattern in the file system.
+     *
+     * @throws IOException
+     */
+    public static Path getConcretePathFromGlob(String pattern, Job job) throws IOException
{
+        Path path = new Path(pattern);
+        FileSystem fs = FileSystem.get(path.toUri(), job.getConfiguration());
+        FileStatus[] matchedFiles = fs.globStatus(path, PATH_FILTER);
+        if (matchedFiles == null || matchedFiles.length == 0) {
+            return null;
+        }
+        return matchedFiles[0].getPath();
+    }
+
     /** check whether there is NO directory in the input file (status) list*/
     public static boolean noDir(FileStatus [] ss) {
         for (FileStatus s : ss) {

Modified: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/TestAvroStorage.java
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/TestAvroStorage.java?rev=1364197&r1=1364196&r2=1364197&view=diff
==============================================================================
--- pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/TestAvroStorage.java
(original)
+++ pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/TestAvroStorage.java
Sun Jul 22 00:30:45 2012
@@ -25,12 +25,16 @@ import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.FileUtil;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.fs.PathFilter;
+import org.apache.hadoop.mapreduce.Job;
 import org.apache.pig.ExecType;
 import org.apache.pig.PigServer;
 import org.apache.pig.backend.executionengine.ExecException;
+import org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.JobCreationException;
+import org.apache.pig.piggybank.storage.avro.AvroStorage;
 import org.apache.pig.piggybank.storage.avro.PigSchema2Avro;
 import org.apache.pig.test.Util;
 import org.junit.AfterClass;
+import org.junit.Assert;
 import org.junit.BeforeClass;
 import org.junit.Test;
 
@@ -64,6 +68,13 @@ public class TestAvroStorage {
         return "file://" + System.getProperty("user.dir") + "/" + basedir + file;
     }
 
+    final private String testDir1 = getInputFile("test_dir1");
+    final private String testDir1AllFiles = getInputFile("test_dir1/*");
+    final private String testDir1Files123 = getInputFile("test_dir1/test_glob{1,2,3}.avro");
+    final private String testDir1Files321 = getInputFile("test_dir1/test_glob{3,2,1}.avro");
+    final private String testDir12AllFiles = getInputFile("{test_dir1,test_dir2}/test_glob*.avro");
+    final private String testDir21AllFiles = getInputFile("{test_dir2,test_dir1}/test_glob*.avro");
+    final private String testNoMatchedFiles = getInputFile("test_dir{1,2}/file_that_does_not_exist*.avro");
     final private String testArrayFile = getInputFile("test_array.avro");
     final private String testRecordFile = getInputFile("test_record.avro");
     final private String testRecordSchema = getInputFile("test_record.avsc");
@@ -83,6 +94,117 @@ public class TestAvroStorage {
     }
 
     @Test
+    public void testDir() throws IOException {
+        // Verify that all files in a directory including its sub-directories are loaded.
+        String output= outbasedir + "testDir";
+        String expected = basedir + "expected_testDir.avro";
+        deleteDirectory(new File(output));
+        String [] queries = {
+           " in = LOAD '" + testDir1 + " ' USING org.apache.pig.piggybank.storage.avro.AvroStorage
();",
+           " STORE in INTO '" + output + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
(" +
+               "   'schema', '{\"type\":\"array\",\"items\":\"float\"}'  );"
+            };
+        testAvroStorage( queries);
+        verifyResults(output, expected);
+    }
+
+    @Test
+    public void testGlob1() throws IOException {
+        // Verify that the a glob pattern matches files properly.
+        String output = outbasedir + "testGlob1";
+        String expected = basedir + "expected_test_dir_1.avro";
+        deleteDirectory(new File(output));
+        String [] queries = {
+           " in = LOAD '" + testDir1AllFiles + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
();",
+           " STORE in INTO '" + output + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
(" +
+               "   'schema', '{\"type\":\"array\",\"items\":\"float\"}'  );"
+            };
+        testAvroStorage(queries);
+        verifyResults(output, expected);
+    }
+
+    @Test
+    public void testGlob2() throws IOException {
+        // Verify that comma-separated filenames are escaped properly.
+        String output = outbasedir + "testGlob2";
+        String expected = basedir + "expected_test_dir_1.avro";
+        deleteDirectory(new File(output));
+        String [] queries = {
+           " in = LOAD '" + testDir1Files123 + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
();",
+           " STORE in INTO '" + output + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
(" +
+               "   'schema', '{\"type\":\"array\",\"items\":\"float\"}'  );"
+            };
+        testAvroStorage(queries);
+        verifyResults(output, expected);
+    }
+
+    @Test
+    public void testGlob3() throws IOException {
+        // Verify that comma-separated filenames are escaped properly.
+        String output = outbasedir + "testGlob3";
+        String expected = basedir + "expected_test_dir_1.avro";
+        deleteDirectory(new File(output));
+        String [] queries = {
+           " in = LOAD '" + testDir1Files321 + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
();",
+           " STORE in INTO '" + output + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
(" +
+               "   'schema', '{\"type\":\"array\",\"items\":\"float\"}'  );"
+            };
+        testAvroStorage(queries);
+        verifyResults(output, expected);
+    }
+
+    @Test
+    public void testGlob4() throws IOException {
+        // Verify that comma-separated directory names are escaped properly.
+        String output = outbasedir + "testGlob4";
+        String expected = basedir + "expected_test_dir_1_2.avro";
+        deleteDirectory(new File(output));
+        String [] queries = {
+           " in = LOAD '" + testDir12AllFiles + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
();",
+           " STORE in INTO '" + output + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
(" +
+               "   'schema', '{\"type\":\"array\",\"items\":\"float\"}'  );"
+            };
+        testAvroStorage(queries);
+        verifyResults(output, expected);
+    }
+
+    @Test
+    public void testGlob5() throws IOException {
+        // Verify that comma-separated directory names are escaped properly.
+        String output = outbasedir + "testGlob5";
+        String expected = basedir + "expected_test_dir_1_2.avro";
+        deleteDirectory(new File(output));
+        String [] queries = {
+           " in = LOAD '" + testDir21AllFiles + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
();",
+           " STORE in INTO '" + output + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
(" +
+               "   'schema', '{\"type\":\"array\",\"items\":\"float\"}'  );"
+            };
+        testAvroStorage(queries);
+        verifyResults(output, expected);
+    }
+
+    @Test
+    public void testGlob6() throws IOException {
+        // Verify that an IOException is thrown if no files are matched by the glob pattern.
+        String output = outbasedir + "testGlob6";
+        deleteDirectory(new File(output));
+        String [] queries = {
+           " in = LOAD '" + testNoMatchedFiles + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
();",
+           " STORE in INTO '" + output + "' USING org.apache.pig.piggybank.storage.avro.AvroStorage
(" +
+               "   'schema', '{\"type\":\"array\",\"items\":\"float\"}'  );"
+            };
+        try {
+            testAvroStorage(queries);
+            Assert.fail();
+        } catch (JobCreationException e) {
+            // The IOException thrown by AvroStorage for input file not found is catched
+            // by the Pig backend, and JobCreationException (a subclass of IOException)
+            // is re-thrown while creating a job configuration.
+            assertEquals(e.getMessage(), "Internal error creating job configuration.");
+        }
+    }
+
+    @Test
     public void testArrayDefault() throws IOException {
         String output= outbasedir + "testArrayDefault";
         String expected = basedir + "expected_testArrayDefault.avro";
@@ -415,7 +537,7 @@ public class TestAvroStorage {
               count++;
             }        
             in.close();
-            assertEquals(count, expected.size());
+            assertEquals(expected.size(), count);
           }
         }
       }

Modified: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/TestAvroStorageUtils.java
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/TestAvroStorageUtils.java?rev=1364197&r1=1364196&r2=1364197&view=diff
==============================================================================
--- pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/TestAvroStorageUtils.java
(original)
+++ pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/TestAvroStorageUtils.java
Sun Jul 22 00:30:45 2012
@@ -17,8 +17,12 @@
 package org.apache.pig.piggybank.test.storage.avro;
 
 import org.apache.avro.Schema;
+import org.apache.hadoop.conf.Configuration;
+import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.mapreduce.Job;
 import org.apache.pig.piggybank.storage.avro.AvroStorageUtils;
 
+import org.junit.Assert;
 import org.junit.Test;
 
 import java.io.IOException;
@@ -122,4 +126,41 @@ public class TestAvroStorageUtils {
         assertNull(realSchema);
     }
 
+    @Test
+    public void testGetConcretePathFromGlob() throws IOException {
+        final String defaultscheme = "file:";
+        final String basedir = System.getProperty("user.dir");
+        final String tempdir = Long.toString(System.currentTimeMillis());
+        final String nonexistentpath = basedir + "/" + tempdir + "/this_path_does_not_exist";
+
+        Path[] paths = null;
+        Path concretePath = null;
+        Job job = new Job(new Configuration());
+
+        // existent path
+        String locationStr = basedir;
+        concretePath = AvroStorageUtils.getConcretePathFromGlob(locationStr, job);
+        assertEquals(defaultscheme + basedir, concretePath.toString());
+
+        // non-existent path
+        locationStr = nonexistentpath;
+        concretePath = AvroStorageUtils.getConcretePathFromGlob(locationStr, job);
+        assertEquals(null, concretePath);
+
+        // empty glob pattern
+        locationStr = basedir + "/{}";
+        concretePath = AvroStorageUtils.getConcretePathFromGlob(locationStr, job);
+        assertEquals(null, concretePath);
+
+        // bad glob pattern
+        locationStr = basedir + "/{1,";
+        try {
+            concretePath = AvroStorageUtils.getConcretePathFromGlob(locationStr, job);
+            Assert.fail();
+        } catch (IOException e) {
+            // The message of the exception for illegal file pattern is rather long,
+            // so we simply confirm if it contains 'illegal file pattern'.
+            assertTrue(e.getMessage().contains("Illegal file pattern"));
+        }
+    }
 }

Added: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/expected_testDir.avro
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/expected_testDir.avro?rev=1364197&view=auto
==============================================================================
Binary file - no diff available.

Propchange: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/expected_testDir.avro
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream

Added: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/expected_test_dir_1.avro
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/expected_test_dir_1.avro?rev=1364197&view=auto
==============================================================================
Binary file - no diff available.

Propchange: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/expected_test_dir_1.avro
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream

Added: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/expected_test_dir_1_2.avro
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/expected_test_dir_1_2.avro?rev=1364197&view=auto
==============================================================================
Binary file - no diff available.

Propchange: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/expected_test_dir_1_2.avro
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream

Added: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_glob1.avro
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_glob1.avro?rev=1364197&view=auto
==============================================================================
Binary file - no diff available.

Propchange: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_glob1.avro
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream

Added: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_glob2.avro
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_glob2.avro?rev=1364197&view=auto
==============================================================================
Binary file - no diff available.

Propchange: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_glob2.avro
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream

Added: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_glob3.avro
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_glob3.avro?rev=1364197&view=auto
==============================================================================
Binary file - no diff available.

Propchange: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_glob3.avro
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream

Added: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_subdir/test_glob4.avro
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_subdir/test_glob4.avro?rev=1364197&view=auto
==============================================================================
Binary file - no diff available.

Propchange: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_subdir/test_glob4.avro
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream

Added: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_subdir/test_glob5.avro
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_subdir/test_glob5.avro?rev=1364197&view=auto
==============================================================================
Binary file - no diff available.

Propchange: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir1/test_subdir/test_glob5.avro
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream

Added: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir2/test_glob4.avro
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir2/test_glob4.avro?rev=1364197&view=auto
==============================================================================
Binary file - no diff available.

Propchange: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir2/test_glob4.avro
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream

Added: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir2/test_glob5.avro
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir2/test_glob5.avro?rev=1364197&view=auto
==============================================================================
Binary file - no diff available.

Propchange: pig/trunk/contrib/piggybank/java/src/test/java/org/apache/pig/piggybank/test/storage/avro/avro_test_files/test_dir2/test_glob5.avro
------------------------------------------------------------------------------
    svn:mime-type = application/octet-stream



Mime
View raw message