Repository: metamodel Updated Branches: refs/heads/master e02c4761d -> a2701136f
METAMODEL-162: Fixed Fixes #32 Project: http://git-wip-us.apache.org/repos/asf/metamodel/repo Commit: http://git-wip-us.apache.org/repos/asf/metamodel/commit/a2701136 Tree: http://git-wip-us.apache.org/repos/asf/metamodel/tree/a2701136 Diff: http://git-wip-us.apache.org/repos/asf/metamodel/diff/a2701136 Branch: refs/heads/master Commit: a2701136f9270db3917e120dbc2f90be770be148 Parents: e02c476 Author: Kasper Sørensen <[email protected]> Authored: Mon Jul 20 08:59:42 2015 +0200 Committer: Kasper Sørensen <[email protected]> Committed: Mon Jul 20 08:59:42 2015 +0200 ---------------------------------------------------------------------- CHANGES.md | 1 + .../org/apache/metamodel/util/HdfsResource.java | 27 +++++++++++++++++++- 2 files changed, 27 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/metamodel/blob/a2701136/CHANGES.md ---------------------------------------------------------------------- diff --git a/CHANGES.md b/CHANGES.md index 3426d3e..6017760 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -1,6 +1,7 @@ ### Apache MetaModel (work in progress) * [METAMODEL-160] - Added support for Apache Hive via the JDBC module of MetaModel. + * [METAMODEL-162] - Made HdfsResource Serializable and added property getters ### Apache MetaModel 4.3.5 http://git-wip-us.apache.org/repos/asf/metamodel/blob/a2701136/hadoop/src/main/java/org/apache/metamodel/util/HdfsResource.java ---------------------------------------------------------------------- diff --git a/hadoop/src/main/java/org/apache/metamodel/util/HdfsResource.java b/hadoop/src/main/java/org/apache/metamodel/util/HdfsResource.java index c2f38ce..f66b8c9 100644 --- a/hadoop/src/main/java/org/apache/metamodel/util/HdfsResource.java +++ b/hadoop/src/main/java/org/apache/metamodel/util/HdfsResource.java @@ -21,6 +21,7 @@ package org.apache.metamodel.util; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; +import java.io.Serializable; import java.util.Arrays; import java.util.regex.Matcher; import java.util.regex.Pattern; @@ -35,7 +36,9 @@ import org.apache.metamodel.MetaModelException; * A {@link Resource} implementation that connects to Apache Hadoop's HDFS * distributed file system. */ -public class HdfsResource implements Resource { +public class HdfsResource implements Resource, Serializable { + + private static final long serialVersionUID = 1L; private static final Pattern URL_PATTERN = Pattern.compile("hdfs://(.+):([0-9]+)/(.*)"); @@ -64,12 +67,34 @@ public class HdfsResource implements Resource { _filepath = '/' + matcher.group(3); } + /** + * Creates a {@link HdfsResource} + * + * @param hostname + * the HDFS (namenode) hostname + * @param port + * the HDFS (namenode) port number + * @param filepath + * the path on HDFS to the file, starting with slash ('/') + */ public HdfsResource(String hostname, int port, String filepath) { _hostname = hostname; _port = port; _filepath = filepath; } + public String getFilepath() { + return _filepath; + } + + public String getHostname() { + return _hostname; + } + + public int getPort() { + return _port; + } + @Override public String getName() { final int lastSlash = _filepath.lastIndexOf('/');
