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.