From e9d9eeaf7b640024792a259ad39f34048f986032 Mon Sep 17 00:00:00 2001 From: Jonathan Hsieh Date: Wed, 13 Feb 2013 18:57:38 +0000 Subject: [PATCH] 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/branches/hbase-7290@1445850 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/hadoop/hbase/io/FileLink.java | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FileLink.java b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FileLink.java index 4bd8eaa55e4..621d6df42c4 100644 --- a/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FileLink.java +++ b/hbase-server/src/main/java/org/apache/hadoop/hbase/io/FileLink.java @@ -18,7 +18,6 @@ package org.apache.hadoop.hbase.io; -import java.util.ArrayList; import java.util.Collection; import java.io.IOException; @@ -27,7 +26,6 @@ import java.io.FileNotFoundException; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.classification.InterfaceAudience; import org.apache.hadoop.fs.FSDataInputStream; 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.PositionedReadable; 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. @@ -405,7 +401,7 @@ public class FileLink { * @throws IOException on unexpected error. */ 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)); } /**