removed print messages and corrected comments
Project: http://git-wip-us.apache.org/repos/asf/vxquery/repo Commit: http://git-wip-us.apache.org/repos/asf/vxquery/commit/215aab96 Tree: http://git-wip-us.apache.org/repos/asf/vxquery/tree/215aab96 Diff: http://git-wip-us.apache.org/repos/asf/vxquery/diff/215aab96 Branch: refs/heads/steven/hdfs Commit: 215aab9634eef6c57cadbcafecdad0fea05b15cf Parents: 4bbd683 Author: efikalti <[email protected]> Authored: Sat Jun 13 19:26:12 2015 +0300 Committer: efikalti <[email protected]> Committed: Sat Jun 13 19:26:12 2015 +0300 ---------------------------------------------------------------------- .../src/main/java/org/apache/vxquery/hdfs2/HDFSFunctions.java | 4 ++-- .../vxquery/metadata/VXQueryCollectionOperatorDescriptor.java | 2 -- 2 files changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/vxquery/blob/215aab96/vxquery-core/src/main/java/org/apache/vxquery/hdfs2/HDFSFunctions.java ---------------------------------------------------------------------- diff --git a/vxquery-core/src/main/java/org/apache/vxquery/hdfs2/HDFSFunctions.java b/vxquery-core/src/main/java/org/apache/vxquery/hdfs2/HDFSFunctions.java index 2281233..24b16da 100644 --- a/vxquery-core/src/main/java/org/apache/vxquery/hdfs2/HDFSFunctions.java +++ b/vxquery-core/src/main/java/org/apache/vxquery/hdfs2/HDFSFunctions.java @@ -33,7 +33,7 @@ public class HDFSFunctions { /** * Create the configuration and add the paths for core-site and hdfs-site as resources. - * Initialize an instance a hdfs FileSystem for this configuration. + * Initialize an instance of HDFS FileSystem for this configuration. * @param hadoop_conf_filepath */ public HDFSFunctions() @@ -186,7 +186,7 @@ public class HDFSFunctions { } /** - * Get instance of the hdfs file system if it is configured correctly. + * Get instance of the HDFSfile system if it is configured correctly. * Return null if there is no instance. * @return */ http://git-wip-us.apache.org/repos/asf/vxquery/blob/215aab96/vxquery-core/src/main/java/org/apache/vxquery/metadata/VXQueryCollectionOperatorDescriptor.java ---------------------------------------------------------------------- diff --git a/vxquery-core/src/main/java/org/apache/vxquery/metadata/VXQueryCollectionOperatorDescriptor.java b/vxquery-core/src/main/java/org/apache/vxquery/metadata/VXQueryCollectionOperatorDescriptor.java index 91a6089..d0fbfe2 100644 --- a/vxquery-core/src/main/java/org/apache/vxquery/metadata/VXQueryCollectionOperatorDescriptor.java +++ b/vxquery-core/src/main/java/org/apache/vxquery/metadata/VXQueryCollectionOperatorDescriptor.java @@ -101,7 +101,6 @@ public class VXQueryCollectionOperatorDescriptor extends AbstractSingleActivityO //check if directory is in the local file system if(collectionDirectory.exists()) { - System.out.println("searching in local for file : " + collectionDirectory.getName()); // Go through each tuple. if (collectionDirectory.isDirectory()) { for (int tupleIndex = 0; tupleIndex < fta.getTupleCount(); ++tupleIndex) { @@ -124,7 +123,6 @@ public class VXQueryCollectionOperatorDescriptor extends AbstractSingleActivityO //else check in HDFS file system else { - System.out.println("searching in hdfs for directory : " + collectionDirectory.getName()); HDFSFunctions hdfs = new HDFSFunctions(); FileSystem fs = hdfs.getFileSystem(); if (fs != null)
