Top Description Methods

org.apache.avro.file

public Interface FileReader<D>

Known Direct Implementers: org.apache.avro.file.DataFileReader, org.apache.avro.file.DataFileReader12
Imports: java.io.IOException, .Closeable, java.util.Iterator, .NoSuchElementException, org.apache.avro.Schema

Interface for reading data from a file.

Method Summary

Modifier and Type	Method and Description
public Schema	getSchema() Return the schema for data in this file.
public D	next(D an instance to reuse. reuse) Read the next datum from the file.
public boolean	pastSync(long position) Return true if past the next synchronization point after a position.
public void	sync(long position) Move to the next synchronization point after a position.
public long	tell() Return the current position in the input.

Inherited from java.io.Closeable:: close
Inherited from java.lang.Iterable:: forEach iterator spliterator
Inherited from java.util.Iterator:: forEachRemaining hasNext next remove

Method Detail

getSchema	back to summary
public Schema getSchema() Return the schema for data in this file.

next

back to summary

public D next(D reuse) throws IOException

Read the next datum from the file.

Parameters

reuse:D: an instance to reuse.

Exceptions

NoSuchElementException:: if no more remain in the file.

pastSync	back to summary
public boolean pastSync(long position) throws IOException Return true if past the next synchronization point after a position.

sync	back to summary
public void sync(long position) throws IOException Move to the next synchronization point after a position. To process a range of file entires, call this with the starting position, then check `pastSync(long)` with the end point before each call to `next()`.

tell	back to summary
public long tell() throws IOException Return the current position in the input.