Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-7552 Pass bufferSize param to FileLinkInputStream constructor within FileLink.open method, and remove unnecessary import packages (Julian Zhou) 

git-svn-id: https://svn.apache.org/repos/asf/hbase/trunk@1433112 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Zhihong Yu 2013-01-14 20:40:48 +00:00
parent 64147bd02f
commit 920153a859
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
hbase-server/src/main/java/org/apache/hadoop/hbase/io/FileLink.java
View File

@ -18,7 +18,6 @@
package org.apache.hadoop.hbase.io; package org.apache.hadoop.hbase.io;
import java.util.ArrayList;
import java.util.Collection; import java.util.Collection;
import java.io.IOException; import java.io.IOException;
@ -27,7 +26,6 @@ import java.io.FileNotFoundException;
import org.apache.commons.logging.Log; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory; import org.apache.commons.logging.LogFactory;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.classification.InterfaceAudience; import org.apache.hadoop.classification.InterfaceAudience;
import org.apache.hadoop.fs.FSDataInputStream; import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.FileSystem;
@ -35,8 +33,6 @@ import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.Path; import org.apache.hadoop.fs.Path;
import org.apache.hadoop.fs.PositionedReadable; import org.apache.hadoop.fs.PositionedReadable;
import org.apache.hadoop.fs.Seekable; import org.apache.hadoop.fs.Seekable;
import org.apache.hadoop.hbase.HConstants;
import org.apache.hadoop.hbase.util.FSUtils;
/** /**
* The FileLink is a sort of hardlink, that allows access to a file given a set of locations. * The FileLink is a sort of hardlink, that allows access to a file given a set of locations.
@ -405,7 +401,7 @@ public class FileLink {
* @throws IOException on unexpected error. * @throws IOException on unexpected error.
*/ */
public FSDataInputStream open(final FileSystem fs, int bufferSize) throws IOException { public FSDataInputStream open(final FileSystem fs, int bufferSize) throws IOException {
return new FSDataInputStream(new FileLinkInputStream(fs, this)); return new FSDataInputStream(new FileLinkInputStream(fs, this, bufferSize));
} }
/** /**