Skip to content

Commit 12c95ff

Browse files
committed
HADOOP-19131. Assist reflection IO with WrappedOperations class
Change-Id: Ia70557518cacab9fd3c9811b6f94bc87afc36395
1 parent 666b0c1 commit 12c95ff

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/io/WrappedOperations.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
import org.apache.hadoop.fs.FileStatus;
2828
import org.apache.hadoop.fs.FileSystem;
2929
import org.apache.hadoop.fs.FutureDataInputStreamBuilder;
30+
import org.apache.hadoop.fs.Path;
3031
import org.apache.hadoop.util.functional.FutureIO;
3132

3233
import static org.apache.hadoop.fs.Options.OpenFileOptions.FS_OPTION_OPENFILE_READ_POLICY;
@@ -49,7 +50,7 @@ private WrappedOperations() {
4950

5051
/**
5152
* OpenFile assistant, easy reflection-based access to
52-
* {@link FileSystem#openFile(org.apache.hadoop.fs.Path)}.
53+
* {@link FileSystem#openFile(Path)}.
5354
* @param fs filesystem
5455
* @param path path
5556
* @param policy read policy
@@ -58,8 +59,10 @@ private WrappedOperations() {
5859
* @return an opened file
5960
* @throws IOException for any failure.
6061
*/
61-
public static FSDataInputStream openFile(final FileSystem fs,
62-
final org.apache.hadoop.fs.Path path,
62+
@InterfaceStability.Stable
63+
public static FSDataInputStream openFile(
64+
final FileSystem fs,
65+
final Path path,
6366
final String policy,
6467
final FileStatus status,
6568
final Map<String, String> options) throws IOException {

0 commit comments

Comments
 (0)