You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hbase.apache.org by el...@apache.org on 2019/02/19 23:10:23 UTC
[hbase] branch branch-2.0 updated: HBASE-21915 Make
FileLinkInputStream implement CanUnbuffer
This is an automated email from the ASF dual-hosted git repository.
elserj pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/hbase.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 7241882 HBASE-21915 Make FileLinkInputStream implement CanUnbuffer
7241882 is described below
commit 724188246362a737404cc55da0996c543f295e46
Author: Josh Elser <el...@apache.org>
AuthorDate: Fri Feb 15 15:59:30 2019 -0500
HBASE-21915 Make FileLinkInputStream implement CanUnbuffer
Signed-off-by: Wellington Chevreuil <we...@gmail.com>
Signed-off-by: Esteban Gutierrez <es...@apache.org>
---
.../src/main/java/org/apache/hadoop/hbase/io/FileLink.java | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
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 42f3483..36e086a 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
@@ -31,6 +31,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.hadoop.fs.CanSetDropBehind;
import org.apache.hadoop.fs.CanSetReadahead;
+import org.apache.hadoop.fs.CanUnbuffer;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.FileStatus;
@@ -102,7 +103,7 @@ public class FileLink {
* and the alternative locations, when the file is moved.
*/
private static class FileLinkInputStream extends InputStream
- implements Seekable, PositionedReadable, CanSetDropBehind, CanSetReadahead {
+ implements Seekable, PositionedReadable, CanSetDropBehind, CanSetReadahead, CanUnbuffer {
private FSDataInputStream in = null;
private Path currentPath = null;
private long pos = 0;
@@ -281,6 +282,14 @@ public class FileLink {
return false;
}
+ @Override
+ public void unbuffer() {
+ if (in == null) {
+ return;
+ }
+ in.unbuffer();
+ }
+
/**
* Try to open the file from one of the available locations.
*