org.expasy.mzjava.avro.io

Class AbstractAvroWriter<O>

java.lang.Object

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

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

All Implemented Interfaces:

AvroExternalizable, AvroWriter<O>

Direct Known Subclasses:

AbstractAminoAcidSequenceWriter, AbstractLibPeakAnnotationWriter, AbstractPeakListWriter, CompositionWriter, ModificationWriter, NumericMassWriter, PeakWriter, PepFragAnnotationWriter, RetentionTimeDiscreteWriter, RetentionTimeIntervalWriter, RetentionTimeListWriter, ScanNumberDiscreteWriter, ScanNumberIntervalWriter, ScanNumberListWriter, UUIDWriter

public abstract class AbstractAvroWriter<O>
extends AvroIO<AbstractAvroWriter>
implements AvroWriter<O>

Base class for writing objects using Avro Encoder

Version:

1.0

Author:

Oliver Horlacher

Constructor Summary

Constructors

Constructor and Description
AbstractAvroWriter()

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> void	writeArray(AbstractAvroWriter<C> writer, Collection<C> list, org.apache.avro.io.Encoder out) Write an array of the objects in list
protected <K,V> void	writeMap(AbstractAvroWriter<V> writer, Map<K,V> map, com.google.common.base.Function<K,String> keyExtractor, org.apache.avro.io.Encoder out)
protected <K> void	writeMap(Map<K,? extends Number> map, com.google.common.base.Function<K,String> keyExtractor, org.apache.avro.io.Encoder out)
protected <K> void	writeMap(gnu.trove.map.TObjectDoubleMap<K> map, com.google.common.base.Function<K,String> keyExtractor, org.apache.avro.io.Encoder out)
protected <C> void	writeOptional(AbstractAvroWriter<C> writer, com.google.common.base.Optional<C> optional, org.apache.avro.io.Encoder out) Write an Optional, this writes a union with null
protected void	writeStringArray(Collection<String> strings, org.apache.avro.io.Encoder out) Writes a collection containing strings as an array
<C> void	writeUnion(Class<C> recordSuperclass, C o, org.apache.avro.io.Encoder out) Write a union
protected <C> void	writeUnionArray(Class<C> recordSuperclass, Collection<C> list, org.apache.avro.io.Encoder out) Write an array containing a union

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.AvroWriter

write

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

createSchema, getObjectClass

Constructor Detail

AbstractAvroWriter

public AbstractAvroWriter()

Method Detail

getRecordName

protected String getRecordName()

Description copied from class: AvroIO

Return the name of this record

Specified by:

getRecordName in class AvroIO<AbstractAvroWriter>

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<AbstractAvroWriter>

Returns:

the namespace of this record

writeUnion

public <C> void writeUnion(Class<C> recordSuperclass,
                  C o,
                  org.apache.avro.io.Encoder out)
                throws IOException

Write a union

Type Parameters:

C - the class of the object to be written

Parameters:

recordSuperclass - the superclass of the union

o - the object

out - the encoder

Throws:

IOException

writeOptional

protected <C> void writeOptional(AbstractAvroWriter<C> writer,
                     com.google.common.base.Optional<C> optional,
                     org.apache.avro.io.Encoder out)
                      throws IOException

Write an Optional, this writes a union with null

Type Parameters:

C - the class of the object to be written

Parameters:

writer - the writer for the object in the Optional

optional - the Optional

out - the encoder

Throws:

IOException

writeUnionArray

protected <C> void writeUnionArray(Class<C> recordSuperclass,
                       Collection<C> list,
                       org.apache.avro.io.Encoder out)
                        throws IOException

Write an array containing a union

Type Parameters:

C - The class of the superclass

Parameters:

recordSuperclass - the superclass of the union

list - the collection that contains the values that are to be written

out - the encoder

Throws:

IOException

writeArray

protected <C> void writeArray(AbstractAvroWriter<C> writer,
                  Collection<C> list,
                  org.apache.avro.io.Encoder out)
                   throws IOException

Write an array of the objects in list

Type Parameters:

C - the class of the objects in the collection

Parameters:

writer - the writer for the objects on the collection

list - the collection to be written

out - the encoder

Throws:

IOException

writeStringArray

protected void writeStringArray(Collection<String> strings,
                    org.apache.avro.io.Encoder out)
                         throws IOException

Writes a collection containing strings as an array

Parameters:

strings - the collection of strings

out - the encoder

Throws:

IOException

writeMap

protected <K,V> void writeMap(AbstractAvroWriter<V> writer,
                  Map<K,V> map,
                  com.google.common.base.Function<K,String> keyExtractor,
                  org.apache.avro.io.Encoder out)
                 throws IOException

Throws:

IOException

writeMap

protected <K> void writeMap(gnu.trove.map.TObjectDoubleMap<K> map,
                com.google.common.base.Function<K,String> keyExtractor,
                org.apache.avro.io.Encoder out)
                 throws IOException

Throws:

IOException

writeMap

protected <K> void writeMap(Map<K,? extends Number> map,
                com.google.common.base.Function<K,String> keyExtractor,
                org.apache.avro.io.Encoder out)
                 throws IOException

Throws:

IOException