org.apache.gora.avro.mapreduce
Class FsInput
java.lang.Object
org.apache.gora.avro.mapreduce.FsInput
- All Implemented Interfaces:
- Closeable, org.apache.avro.file.SeekableInput
public class FsInput
- extends Object
- implements Closeable, org.apache.avro.file.SeekableInput
Adapt an FSDataInputStream
to SeekableInput
.
Constructor Summary |
FsInput(org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration conf)
Construct given a path and a configuration. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
FsInput
public FsInput(org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration conf)
throws IOException
- Construct given a path and a configuration.
- Throws:
IOException
length
public long length()
- Specified by:
length
in interface org.apache.avro.file.SeekableInput
read
public int read(byte[] b,
int off,
int len)
throws IOException
- Specified by:
read
in interface org.apache.avro.file.SeekableInput
- Throws:
IOException
seek
public void seek(long p)
throws IOException
- Specified by:
seek
in interface org.apache.avro.file.SeekableInput
- Throws:
IOException
tell
public long tell()
throws IOException
- Specified by:
tell
in interface org.apache.avro.file.SeekableInput
- Throws:
IOException
close
public void close()
throws IOException
- Specified by:
close
in interface Closeable
- Throws:
IOException
Copyright © 2010-2013 The Apache Software Foundation. All Rights Reserved.