You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by cu...@apache.org on 2006/02/24 22:37:20 UTC
svn commit: r380825 - in /lucene/hadoop/trunk/src/java/org/apache/hadoop/fs:
FSDataOutputStream.java FileSystem.java
Author: cutting
Date: Fri Feb 24 13:37:18 2006
New Revision: 380825
URL: http://svn.apache.org/viewcvs?rev=380825&view=rev
Log:
Fix for HADOOP-40. Buffer size was ignored.
Modified:
lucene/hadoop/trunk/src/java/org/apache/hadoop/fs/FSDataOutputStream.java
lucene/hadoop/trunk/src/java/org/apache/hadoop/fs/FileSystem.java
Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/fs/FSDataOutputStream.java
URL: http://svn.apache.org/viewcvs/lucene/hadoop/trunk/src/java/org/apache/hadoop/fs/FSDataOutputStream.java?rev=380825&r1=380824&r2=380825&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/fs/FSDataOutputStream.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/fs/FSDataOutputStream.java Fri Feb 24 13:37:18 2006
@@ -122,19 +122,20 @@
}
public FSDataOutputStream(FileSystem fs, File file,
- boolean overwrite, Configuration conf)
+ boolean overwrite, Configuration conf,
+ int bufferSize)
throws IOException {
super(new Buffer(new PositionCache(new Summer(fs, file, overwrite, conf)),
- conf.getInt("io.file.buffer.size", 4096)));
+ bufferSize));
}
/** Construct without checksums. */
- public FSDataOutputStream(FSOutputStream out, Configuration conf) throws IOException {
+ private FSDataOutputStream(FSOutputStream out, Configuration conf) throws IOException {
this(out, conf.getInt("io.file.buffer.size", 4096));
}
/** Construct without checksums. */
- public FSDataOutputStream(FSOutputStream out, int bufferSize)
+ private FSDataOutputStream(FSOutputStream out, int bufferSize)
throws IOException {
super(new Buffer(new PositionCache(out), bufferSize));
}
Modified: lucene/hadoop/trunk/src/java/org/apache/hadoop/fs/FileSystem.java
URL: http://svn.apache.org/viewcvs/lucene/hadoop/trunk/src/java/org/apache/hadoop/fs/FileSystem.java?rev=380825&r1=380824&r2=380825&view=diff
==============================================================================
--- lucene/hadoop/trunk/src/java/org/apache/hadoop/fs/FileSystem.java (original)
+++ lucene/hadoop/trunk/src/java/org/apache/hadoop/fs/FileSystem.java Fri Feb 24 13:37:18 2006
@@ -177,7 +177,7 @@
*/
public FSDataOutputStream create(File f, boolean overwrite,
int bufferSize) throws IOException {
- return new FSDataOutputStream(this, f, overwrite, getConf());
+ return new FSDataOutputStream(this, f, overwrite, getConf(), bufferSize);
}
/** Opens an OutputStream at the indicated File.