| 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,
              boolean closeOnError)
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–2019 The Apache Software Foundation. All rights reserved.