Author: rickette
Date: Sat Jun 4 09:27:48 2011
New Revision: 1131358
URL: http://svn.apache.org/viewvc?rev=1131358&view=rev
Log:
CAMEL-4043: Removed obsolete 'localhost' reference
Modified:
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerConsumerTest.java
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerFileWriteTest.java
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerSplitTest.java
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerTest.java
Modified:
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerConsumerTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerConsumerTest.java?rev=1131358&r1=1131357&r2=1131358&view=diff
==============================================================================
---
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerConsumerTest.java
(original)
+++
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerConsumerTest.java
Sat Jun 4 09:27:48 2011
@@ -43,8 +43,8 @@ public class HdfsProducerConsumerTest ex
context.addRoutes(new RouteBuilder() {
@Override
public void configure() {
- from("direct:start").to("hdfs:///localhost/" + file.toUri() +
"?fileSystemType=LOCAL&splitStrategy=BYTES:5,IDLE:1000");
- from("hdfs:///localhost/" + file.toUri() +
"?pattern=seg*&initialDelay=2000&fileSystemType=LOCAL&chunkSize=5").to("mock:result");
+ from("direct:start").to("hdfs:///" + file.toUri() +
"?fileSystemType=LOCAL&splitStrategy=BYTES:5,IDLE:1000");
+ from("hdfs:///" + file.toUri() +
"?pattern=seg*&initialDelay=2000&fileSystemType=LOCAL&chunkSize=5").to("mock:result");
}
});
context.start();
Modified:
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerFileWriteTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerFileWriteTest.java?rev=1131358&r1=1131357&r2=1131358&view=diff
==============================================================================
---
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerFileWriteTest.java
(original)
+++
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerFileWriteTest.java
Sat Jun 4 09:27:48 2011
@@ -49,7 +49,7 @@ public class HdfsProducerFileWriteTest e
@Override
public void configure() throws Exception {
from("file://target/file-batch1?sortBy=file:name")
- .to("hdfs://localhost/" + file.toUri() +
"?fileSystemType=LOCAL");
+ .to("hdfs:///" + file.toUri() +
"?fileSystemType=LOCAL");
}
});
@@ -84,7 +84,7 @@ public class HdfsProducerFileWriteTest e
@Override
public void configure() throws Exception {
from("file://target/file-batch2?sortBy=file:name")
- .to("hdfs://localhost/" + file.toUri() +
"?fileSystemType=LOCAL&fileType=SEQUENCE_FILE");
+ .to("hdfs:///" + file.toUri() +
"?fileSystemType=LOCAL&fileType=SEQUENCE_FILE");
}
});
@@ -124,7 +124,7 @@ public class HdfsProducerFileWriteTest e
public void configure() throws Exception {
from("file://target/file-batch3?sortBy=file:name")
.setHeader("KEY").simple("${in.header.CamelFileName}")
- .to("hdfs://localhost/" + file.toUri() +
"?fileSystemType=LOCAL&keyType=TEXT&fileType=SEQUENCE_FILE");
+ .to("hdfs:///" + file.toUri() +
"?fileSystemType=LOCAL&keyType=TEXT&fileType=SEQUENCE_FILE");
}
});
@@ -165,7 +165,7 @@ public class HdfsProducerFileWriteTest e
public void configure() throws Exception {
from("file://target/file-batch4?sortBy=file:name")
.setHeader("KEY").simple("${in.header.CamelFileName}")
- .to("hdfs://localhost/" + file.toUri() +
"?fileSystemType=LOCAL&keyType=TEXT&fileType=MAP_FILE");
+ .to("hdfs:///" + file.toUri() +
"?fileSystemType=LOCAL&keyType=TEXT&fileType=MAP_FILE");
}
});
@@ -204,7 +204,7 @@ public class HdfsProducerFileWriteTest e
@Override
public void configure() throws Exception {
from("file://target/file-batch5?sortBy=file:name")
- .to("hdfs://localhost/" + file.toUri() +
"?fileSystemType=LOCAL&fileType=SEQUENCE_FILE&splitStrategy=IDLE:100&checkIdleInterval=10");
+ .to("hdfs:///" + file.toUri() +
"?fileSystemType=LOCAL&fileType=SEQUENCE_FILE&splitStrategy=IDLE:100&checkIdleInterval=10");
}
});
Modified:
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerSplitTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerSplitTest.java?rev=1131358&r1=1131357&r2=1131358&view=diff
==============================================================================
---
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerSplitTest.java
(original)
+++
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerSplitTest.java
Sat Jun 4 09:27:48 2011
@@ -108,11 +108,11 @@ public class HdfsProducerSplitTest exten
return new RouteBuilder() {
@Override
public void configure() throws Exception {
- from("direct:start1").to("hdfs://localhost/" +
BASE_FILE.toUri() + "1?fileSystemType=LOCAL&splitStrategy=MESSAGES:1");
- from("direct:start2").to("hdfs://localhost/" +
BASE_FILE.toUri() + "2?fileSystemType=LOCAL&splitStrategy=BYTES:5");
- from("direct:start3").to("hdfs://localhost/" +
BASE_FILE.toUri() + "3?fileSystemType=LOCAL&splitStrategy=IDLE:1000");
- from("direct:start4").to("hdfs://localhost/" +
BASE_FILE.toUri() +
"4?fileSystemType=LOCAL&splitStrategy=IDLE:1000,MESSAGES:1");
- from("direct:start5").to("hdfs://localhost/" +
BASE_FILE.toUri() + "5?fileSystemType=LOCAL&splitStrategy=IDLE:1000,BYTES:5");
+ from("direct:start1").to("hdfs:///" + BASE_FILE.toUri() +
"1?fileSystemType=LOCAL&splitStrategy=MESSAGES:1");
+ from("direct:start2").to("hdfs:///" + BASE_FILE.toUri() +
"2?fileSystemType=LOCAL&splitStrategy=BYTES:5");
+ from("direct:start3").to("hdfs:///" + BASE_FILE.toUri() +
"3?fileSystemType=LOCAL&splitStrategy=IDLE:1000");
+ from("direct:start4").to("hdfs:///" + BASE_FILE.toUri() +
"4?fileSystemType=LOCAL&splitStrategy=IDLE:1000,MESSAGES:1");
+ from("direct:start5").to("hdfs:///" + BASE_FILE.toUri() +
"5?fileSystemType=LOCAL&splitStrategy=IDLE:1000,BYTES:5");
}
};
}
Modified:
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerTest.java
URL:
http://svn.apache.org/viewvc/camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerTest.java?rev=1131358&r1=1131357&r2=1131358&view=diff
==============================================================================
---
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerTest.java
(original)
+++
camel/trunk/components/camel-hdfs/src/test/java/org/apache/camel/component/hdfs/HdfsProducerTest.java
Sat Jun 4 09:27:48 2011
@@ -256,33 +256,33 @@ public class HdfsProducerTest extends Ca
@Override
public void configure() throws Exception {
- from("direct:start1").to("hdfs://localhost/" +
TEMP_DIR.toUri() +
"test-camel1?fileSystemType=LOCAL&valueType=TEXT&fileType=SEQUENCE_FILE");
+ from("direct:start1").to("hdfs:///" + TEMP_DIR.toUri() +
"test-camel1?fileSystemType=LOCAL&valueType=TEXT&fileType=SEQUENCE_FILE");
/* For testing writables */
- from("direct:write_boolean").to("hdfs://localhost/" +
TEMP_DIR.toUri() +
"test-camel-boolean?fileSystemType=LOCAL&valueType=BOOLEAN&fileType=SEQUENCE_FILE");
+ from("direct:write_boolean").to("hdfs:///" + TEMP_DIR.toUri()
+
"test-camel-boolean?fileSystemType=LOCAL&valueType=BOOLEAN&fileType=SEQUENCE_FILE");
- from("direct:write_byte").to("hdfs://localhost/" +
TEMP_DIR.toUri() +
"test-camel-byte?fileSystemType=LOCAL&valueType=BYTE&fileType=SEQUENCE_FILE");
+ from("direct:write_byte").to("hdfs:///" + TEMP_DIR.toUri() +
"test-camel-byte?fileSystemType=LOCAL&valueType=BYTE&fileType=SEQUENCE_FILE");
- from("direct:write_int").to("hdfs://localhost/" +
TEMP_DIR.toUri() +
"test-camel-int?fileSystemType=LOCAL&valueType=INT&fileType=SEQUENCE_FILE");
+ from("direct:write_int").to("hdfs:///" + TEMP_DIR.toUri() +
"test-camel-int?fileSystemType=LOCAL&valueType=INT&fileType=SEQUENCE_FILE");
- from("direct:write_float").to("hdfs://localhost/" +
TEMP_DIR.toUri() +
"test-camel-float?fileSystemType=LOCAL&valueType=FLOAT&fileType=SEQUENCE_FILE");
+ from("direct:write_float").to("hdfs:///" + TEMP_DIR.toUri() +
"test-camel-float?fileSystemType=LOCAL&valueType=FLOAT&fileType=SEQUENCE_FILE");
- from("direct:write_long").to("hdfs://localhost/" +
TEMP_DIR.toUri() +
"test-camel-long?fileSystemType=LOCAL&valueType=LONG&fileType=SEQUENCE_FILE");
+ from("direct:write_long").to("hdfs:///" + TEMP_DIR.toUri() +
"test-camel-long?fileSystemType=LOCAL&valueType=LONG&fileType=SEQUENCE_FILE");
- from("direct:write_double").to("hdfs://localhost/" +
TEMP_DIR.toUri() +
"test-camel-double?fileSystemType=LOCAL&valueType=DOUBLE&fileType=SEQUENCE_FILE");
+ from("direct:write_double").to("hdfs:///" + TEMP_DIR.toUri() +
"test-camel-double?fileSystemType=LOCAL&valueType=DOUBLE&fileType=SEQUENCE_FILE");
- from("direct:write_text1").to("hdfs://localhost/" +
TEMP_DIR.toUri() +
"test-camel-text1?fileSystemType=LOCAL&valueType=TEXT&fileType=SEQUENCE_FILE");
+ from("direct:write_text1").to("hdfs:///" + TEMP_DIR.toUri() +
"test-camel-text1?fileSystemType=LOCAL&valueType=TEXT&fileType=SEQUENCE_FILE");
/* For testing key and value writing */
- from("direct:write_text2").to("hdfs://localhost/" +
TEMP_DIR.toUri() +
"test-camel-text2?fileSystemType=LOCAL&keyType=TEXT&valueType=TEXT&fileType=SEQUENCE_FILE");
+ from("direct:write_text2").to("hdfs:///" + TEMP_DIR.toUri() +
"test-camel-text2?fileSystemType=LOCAL&keyType=TEXT&valueType=TEXT&fileType=SEQUENCE_FILE");
- from("direct:write_text3").to("hdfs://localhost/" +
TEMP_DIR.toUri() +
"test-camel-text3?fileSystemType=LOCAL&keyType=TEXT&valueType=TEXT&fileType=MAP_FILE");
+ from("direct:write_text3").to("hdfs:///" + TEMP_DIR.toUri() +
"test-camel-text3?fileSystemType=LOCAL&keyType=TEXT&valueType=TEXT&fileType=MAP_FILE");
/* For testing ArrayFile */
- from("direct:write_text4").to("hdfs://localhost/" +
TEMP_DIR.toUri() +
"test-camel-text4?fileSystemType=LOCAL&valueType=TEXT&fileType=ARRAY_FILE");
+ from("direct:write_text4").to("hdfs:///" + TEMP_DIR.toUri() +
"test-camel-text4?fileSystemType=LOCAL&valueType=TEXT&fileType=ARRAY_FILE");
/* For testing BloomMapFile */
- from("direct:write_text5").to("hdfs://localhost/" +
TEMP_DIR.toUri() +
"test-camel-text5?fileSystemType=LOCAL&keyType=TEXT&valueType=TEXT&fileType=BLOOMMAP_FILE");
+ from("direct:write_text5").to("hdfs:///" + TEMP_DIR.toUri() +
"test-camel-text5?fileSystemType=LOCAL&keyType=TEXT&valueType=TEXT&fileType=BLOOMMAP_FILE");
}
};
}
