From f7110781bb06141d464a06bd1d853068fa72c5ba Mon Sep 17 00:00:00 2001 From: Josh Elser Date: Fri, 15 Feb 2019 15:59:30 -0500 Subject: [PATCH] HBASE-21915 Make FileLinkInputStream implement CanUnbuffer --- .../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 42f3483648..36e086a596 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. * -- 2.18.0