it.cnr.isti.hpc.io.reader

Class RecordReader<E>

java.lang.Object

it.cnr.isti.hpc.io.reader.RecordReader<E>

All Implemented Interfaces:

Iterable<E>

public class RecordReader<E>
extends Object
implements Iterable<E>

A RecordReader abstracts a collection of objects on a file. Each line of a file represents a serialized object of the collection. RecordReader implements the policy for deserializing each line of the file.

Author:

Diego Ceccarelli

Constructor Summary

Constructors

Constructor and Description
RecordReader(String inputFile, Class<E> clazz) Creates the record reader, it will be possible to iterate on the object serialized on the file inputFile.
RecordReader(String inputFile, RecordParser<E> parser) Creates the record reader, it will be possible to iterate on the object serialized on the file inputFile.

Method Summary

Methods

Modifier and Type	Method and Description
RecordReader<E>	filter(Filter<E>... filters) Add one Filter or more to the reader, only objects that do not match any filter will be returned.
Iterator<E>	iterator()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RecordReader

public RecordReader(String inputFile,
            RecordParser<E> parser)

Creates the record reader, it will be possible to iterate on the object serialized on the file inputFile.

Parameters:

inputFile - the file containing the serialized object (one per line). If the file ends with .gz, a compressed input reader will be used.

parser - the object parser, in order to deserialize each line in a object.

RecordReader

public RecordReader(String inputFile,
            Class<E> clazz)

Creates the record reader, it will be possible to iterate on the object serialized on the file inputFile. It will assume that objects in the file are encoded in json.

Parameters:

inputFile - the file containing the serialized object (one per line). If the file ends with .gz, a compressed input reader will be used.

clazz - the class of the object to parse.

Method Detail

filter

public RecordReader<E> filter(Filter<E>... filters)

Add one Filter or more to the reader, only objects that do not match any filter will be returned.

Parameters:

filters - the list of filter to match against each object.

Returns:

this record reader.

iterator

public Iterator<E> iterator()

Specified by:

iterator in interface Iterable<E>