You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nutch.apache.org by cu...@apache.org on 2005/04/25 22:32:22 UTC
svn commit: r164639 -
/incubator/nutch/trunk/src/java/org/apache/nutch/ndfs/NDFS.java
Author: cutting
Date: Mon Apr 25 13:32:22 2005
New Revision: 164639
URL: http://svn.apache.org/viewcvs?rev=164639&view=rev
Log:
Permit non-default data directory. Patch from Piotr Kosiorowski.
Modified:
incubator/nutch/trunk/src/java/org/apache/nutch/ndfs/NDFS.java
Modified: incubator/nutch/trunk/src/java/org/apache/nutch/ndfs/NDFS.java
URL: http://svn.apache.org/viewcvs/incubator/nutch/trunk/src/java/org/apache/nutch/ndfs/NDFS.java?rev=164639&r1=164638&r2=164639&view=diff
==============================================================================
--- incubator/nutch/trunk/src/java/org/apache/nutch/ndfs/NDFS.java (original)
+++ incubator/nutch/trunk/src/java/org/apache/nutch/ndfs/NDFS.java Mon Apr 25 13:32:22 2005
@@ -411,14 +411,12 @@
Vector receivedBlockList = new Vector();
/**
- * Create using configured defaults.
+ * Create using configured defaults and dataDir.
*/
- public DataNode() throws IOException {
- this(InetAddress.getLocalHost().getHostName(),
- new File(NutchConf.get().get("ndfs.data.dir",
- "/tmp/nutch/data/name")),
- createSocketAddr
- (NutchConf.get().get("fs.default.name", "local")));
+ public DataNode(String dataDir) throws IOException {
+ this(InetAddress.getLocalHost().getHostName(), new File(dataDir),
+ createSocketAddr(NutchConf.get().get("fs.default.name",
+ "local")));
}
/**
@@ -911,7 +909,14 @@
/**
*/
public static void main(String argv[]) throws IOException {
- DataNode datanode = new DataNode();
+ String dataDir = NutchConf.get().get("ndfs.data.dir",
+ "/tmp/nutch/data/name");
+ if (argv.length > 0){
+ dataDir=argv[0];
+ }
+ LOG.info("Using ["+dataDir+"] directory for data storage.");
+
+ DataNode datanode = new DataNode(dataDir);
while (true) {
try {
datanode.offerService();