changes in comments
Project: http://git-wip-us.apache.org/repos/asf/vxquery/repo Commit: http://git-wip-us.apache.org/repos/asf/vxquery/commit/319b79ca Tree: http://git-wip-us.apache.org/repos/asf/vxquery/tree/319b79ca Diff: http://git-wip-us.apache.org/repos/asf/vxquery/diff/319b79ca Branch: refs/heads/steven/hdfs Commit: 319b79ca20d4c714c986c980a09f505d391eb319 Parents: edc7918 Author: efikalti <[email protected]> Authored: Thu Jun 4 20:28:26 2015 +0300 Committer: efikalti <[email protected]> Committed: Thu Jun 4 20:28:26 2015 +0300 ---------------------------------------------------------------------- .../vxquery/metadata/VXQueryCollectionOperatorDescriptor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/vxquery/blob/319b79ca/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 c318162..69bca70 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,7 @@ public class VXQueryCollectionOperatorDescriptor extends AbstractSingleActivityO String collectionModifiedName = collectionName.replace("${nodeId}", nodeId); File collectionDirectory = new File(collectionModifiedName); - //check if it in the local file system + //check if directory is in the local file system if(collectionDirectory.exists()) { // Go through each tuple. @@ -123,7 +123,7 @@ public class VXQueryCollectionOperatorDescriptor extends AbstractSingleActivityO + collectionDirectory.getAbsolutePath() + ") passed to collection."); } } - //check in HDFS file system + //else check in HDFS file system else { HDFSFileFunctions hdfs = new HDFSFileFunctions(hdfs_conf_dir);
