public class FsInput extends Object implements Closeable, org.apache.avro.file.SeekableInput
FSDataInputStream
to SeekableInput
.Constructor and Description |
---|
FsInput(Path path,
Configuration conf)
Construct given a path and a configuration.
|
FsInput(Path path,
FileSystem fileSystem)
Construct given a path and a
FileSystem . |
Modifier and Type | Method and Description |
---|---|
void |
close() |
long |
length() |
int |
read(byte[] b,
int off,
int len) |
void |
seek(long p) |
long |
tell() |
public FsInput(Path path, Configuration conf) throws IOException
IOException
public FsInput(Path path, FileSystem fileSystem) throws IOException
FileSystem
.IOException
public long length()
length
in interface org.apache.avro.file.SeekableInput
public int read(byte[] b, int off, int len) throws IOException
read
in interface org.apache.avro.file.SeekableInput
IOException
public void seek(long p) throws IOException
seek
in interface org.apache.avro.file.SeekableInput
IOException
public long tell() throws IOException
tell
in interface org.apache.avro.file.SeekableInput
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.