org.expasy.mzjava.avro.io

Class AbstractAvroReader<O>

java.lang.Object

org.expasy.mzjava.avro.io.AvroIO<AbstractAvroReader>

org.expasy.mzjava.avro.io.AbstractAvroReader<O>

All Implemented Interfaces:

AvroExternalizable, AvroReader<O>

Direct Known Subclasses:

AbstractAminoAcidSequenceReader, AbstractPeakListReader, CompositionReader, LibPeakAnnotationReader, ModificationReader, NumericMassReader, PeakReader, PepFragAnnotationReader, PepLibPeakAnnotationReader, RetentionTimeDiscreteReader, RetentionTimeIntervalReader, RetentionTimeListReader, ScanNumberDiscreteReader, ScanNumberIntervalReader, ScanNumberListReader, UUIDReader

public abstract class AbstractAvroReader<O>
extends AvroIO<AbstractAvroReader>
implements AvroReader<O>

Base class for reading objects using the Avro Decoder

Version:

1.0

Author:

Oliver Horlacher

Constructor Summary

Constructors

Constructor and Description
AbstractAvroReader()

Method Summary

Methods

Modifier and Type	Method and Description
protected String	getRecordName() Return the name of this record
protected String	getRecordNameSpace() Return the namespace of this record
protected <C extends Collection<E>,E> C	readArray(AbstractAvroReader<E> reader, C collection, org.apache.avro.io.Decoder in) Read an array that contains records into collection
protected <K,V> Map<K,V>	readMap(com.google.common.base.Function<String,K> keyFunction, AbstractAvroReader<V> reader, org.apache.avro.io.Decoder in)
protected <K> gnu.trove.map.TObjectDoubleMap<K>	readMap(com.google.common.base.Function<String,K> keyFunction, org.apache.avro.io.Decoder in)
protected <K,V> Map<K,V>	readMap(com.google.common.base.Function<String,K> keyFunction, com.google.common.base.Function<org.apache.avro.io.Decoder,V> valueFunction, org.apache.avro.io.Decoder in)
protected <C> com.google.common.base.Optional<C>	readOptional(AbstractAvroReader<C> reader, org.apache.avro.io.Decoder in) Read an union of C and null and return a Optional.of() or Optional.absent()
protected <C extends Collection<String>> C	readStringArray(C collection, org.apache.avro.io.Decoder in) Read an the String's from an array into the provided collection.
<C> C	readUnion(Class<C> recordSuperclass, org.apache.avro.io.Decoder in) Read a union
protected <C> void	readUnionArray(Class<C> recordSuperclass, Collection<C> collection, org.apache.avro.io.Decoder in) Read an array that contains unions of classes that have recordSuperclass as a superclass

Methods inherited from class org.expasy.mzjava.avro.io.AvroIO

createEnumSchema, createRecordFields, createSchema, createSchemaField, createUnionSchema, createUnionSchema, getRecordDoc, getUnion, registerUnion, rewriteNameSpace

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.expasy.mzjava.avro.io.AvroReader

read

Methods inherited from interface org.expasy.mzjava.avro.io.AvroExternalizable

createSchema, getObjectClass

Constructor Detail

AbstractAvroReader

public AbstractAvroReader()

Method Detail

getRecordName

protected String getRecordName()

Description copied from class: AvroIO

Return the name of this record

Specified by:

getRecordName in class AvroIO<AbstractAvroReader>

Returns:

the name of this record

getRecordNameSpace

protected String getRecordNameSpace()

Description copied from class: AvroIO

Return the namespace of this record

Specified by:

getRecordNameSpace in class AvroIO<AbstractAvroReader>

Returns:

the namespace of this record

readUnion

public <C> C readUnion(Class<C> recordSuperclass,
              org.apache.avro.io.Decoder in)
            throws IOException

Read a union

Type Parameters:

C - the class of the object to be read

Parameters:

recordSuperclass - the super class of the union

in - the decoder

Returns:

the the record superclass

Throws:

IOException

readUnionArray

protected <C> void readUnionArray(Class<C> recordSuperclass,
                      Collection<C> collection,
                      org.apache.avro.io.Decoder in)
                       throws IOException

Read an array that contains unions of classes that have recordSuperclass as a superclass

Type Parameters:

C - the record superclass

Parameters:

recordSuperclass - the superclass of the union

collection - the collection to read the array into

in - the decoder

Throws:

IOException

readArray

protected <C extends Collection<E>,E> C readArray(AbstractAvroReader<E> reader,
                                      C collection,
                                      org.apache.avro.io.Decoder in)
                                  throws IOException

Read an array that contains records into collection

Type Parameters:

E - the record class

Parameters:

reader - the reader

collection - the collection

in - the decoder

Throws:

IOException

readStringArray

protected <C extends Collection<String>> C readStringArray(C collection,
                                               org.apache.avro.io.Decoder in)
                                        throws IOException

Read an the String's from an array into the provided collection.

Parameters:

in - the decoder

collection - the collection

Returns:

the collection

Throws:

IOException

readOptional

protected <C> com.google.common.base.Optional<C> readOptional(AbstractAvroReader<C> reader,
                                                  org.apache.avro.io.Decoder in)
                                                   throws IOException

Read an union of C and null and return a Optional.of() or Optional.absent()

Type Parameters:

C - the record class

Parameters:

reader - the reader if the value is not null

in - the decoder

Returns:

Optional containing the read record if the record is not null, Optional.absent otherwise

Throws:

IOException

readMap

protected <K,V> Map<K,V> readMap(com.google.common.base.Function<String,K> keyFunction,
                     com.google.common.base.Function<org.apache.avro.io.Decoder,V> valueFunction,
                     org.apache.avro.io.Decoder in)
                    throws IOException

Throws:

IOException

readMap

protected <K> gnu.trove.map.TObjectDoubleMap<K> readMap(com.google.common.base.Function<String,K> keyFunction,
                                            org.apache.avro.io.Decoder in)
                                             throws IOException

Throws:

IOException

readMap

protected <K,V> Map<K,V> readMap(com.google.common.base.Function<String,K> keyFunction,
                     AbstractAvroReader<V> reader,
                     org.apache.avro.io.Decoder in)
                    throws IOException

Throws:

IOException