Package | Description |
---|---|
org.apache.avro.file |
A container file for Avro data.
|
org.apache.avro.mapred |
Run Hadoop MapReduce jobs over
Avro data, with map and reduce functions written in Java.
|
org.apache.avro.mapreduce |
Modifier and Type | Class and Description |
---|---|
class |
SeekableByteArrayInput
A
SeekableInput backed with data in a byte array. |
class |
SeekableFileInput
A
FileInputStream that implements SeekableInput . |
Modifier and Type | Method and Description |
---|---|
DataFileWriter<D> |
DataFileWriter.appendTo(SeekableInput in,
OutputStream out)
Open a writer appending to an existing file.
|
static <D> FileReader<D> |
DataFileReader.openReader(SeekableInput in,
DatumReader<D> reader)
Open a reader for a file.
|
static <D> DataFileReader<D> |
DataFileReader.openReader(SeekableInput in,
DatumReader<D> reader,
DataFileStream.Header header,
boolean sync)
Construct a reader for a file at the current position of the input,
without reading the header.
|
Constructor and Description |
---|
DataFileReader(SeekableInput sin,
DatumReader<D> reader)
Construct a reader for a file.
|
DataFileReader(SeekableInput sin,
DatumReader<D> reader,
DataFileStream.Header header)
Construct using a
DataFileStream.Header . |
DataFileReader12(SeekableInput sin,
DatumReader<D> reader)
Construct a reader for a file.
|
Modifier and Type | Class and Description |
---|---|
class |
FsInput
Adapt an
FSDataInputStream to SeekableInput . |
Modifier and Type | Method and Description |
---|---|
protected SeekableInput |
AvroRecordReaderBase.createSeekableInput(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.Path path)
Creates a seekable input stream to an Avro container file.
|
Modifier and Type | Method and Description |
---|---|
protected DataFileReader<T> |
AvroRecordReaderBase.createAvroFileReader(SeekableInput input,
DatumReader<T> datumReader)
Creates an Avro container file reader from a seekable input stream.
|
Copyright © 2009-2013 The Apache Software Foundation. All Rights Reserved.