You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by an...@apache.org on 2013/10/31 23:01:59 UTC
svn commit: r1537727 - in /pig/branches/branch-0.12: CHANGES.txt
src/org/apache/pig/impl/util/UriUtil.java
Author: aniket486
Date: Thu Oct 31 22:01:59 2013
New Revision: 1537727
URL: http://svn.apache.org/r1537727
Log:
PIG-3552: UriUtil used by reducer estimator should support viewfs (amatsukawa via aniket486)
Modified:
pig/branches/branch-0.12/CHANGES.txt
pig/branches/branch-0.12/src/org/apache/pig/impl/util/UriUtil.java
Modified: pig/branches/branch-0.12/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.12/CHANGES.txt?rev=1537727&r1=1537726&r2=1537727&view=diff
==============================================================================
--- pig/branches/branch-0.12/CHANGES.txt (original)
+++ pig/branches/branch-0.12/CHANGES.txt Thu Oct 31 22:01:59 2013
@@ -22,6 +22,8 @@ Release 0.12.1 (unreleased changes)
IMPROVEMENTS
+PIG-3552: UriUtil used by reducer estimator should support viewfs (amatsukawa via aniket486)
+
PIG-3549: Print hadoop jobids for failed, killed job (aniket486)
PIG-3047: Check the size of a relation before adding it to distributed cache in Replicated join (aniket486)
Modified: pig/branches/branch-0.12/src/org/apache/pig/impl/util/UriUtil.java
URL: http://svn.apache.org/viewvc/pig/branches/branch-0.12/src/org/apache/pig/impl/util/UriUtil.java?rev=1537727&r1=1537726&r2=1537727&view=diff
==============================================================================
--- pig/branches/branch-0.12/src/org/apache/pig/impl/util/UriUtil.java (original)
+++ pig/branches/branch-0.12/src/org/apache/pig/impl/util/UriUtil.java Thu Oct 31 22:01:59 2013
@@ -17,14 +17,11 @@
*/
package org.apache.pig.impl.util;
-import java.io.File;
-
-
public class UriUtil {
public static boolean isHDFSFile(String uri){
if(uri == null)
return false;
- if(uri.startsWith("/") || uri.startsWith("hdfs:")){
+ if(uri.startsWith("/") || uri.startsWith("hdfs:") || uri.startsWith("viewfs:")) {
return true;
}
return false;
@@ -34,7 +31,7 @@ public class UriUtil {
if(uri == null)
return false;
if(uri.startsWith("/") || uri.matches("[A-Za-z]:.*") || uri.startsWith("hdfs:")
- || uri.startsWith("file:") || uri.startsWith("s3n:")){
+ || uri.startsWith("viewfs:") || uri.startsWith("file:") || uri.startsWith("s3n:")) {
return true;
}
return false;