Package org.apache.avro

Class AvroArrayWriter<T>

java.lang.Object

org.apache.avro.AvroArrayWriter<T>

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, Consumer<T>, org.spf4j.base.ArrayWriter<T>

@ThreadSafe
public final class AvroArrayWriter<T>
extends Object
implements org.spf4j.base.ArrayWriter<T>

Author:

Zoltan Farkas

Constructor Summary

Constructors

Constructor	Description
AvroArrayWriter(org.apache.avro.io.Encoder encoder, org.apache.avro.io.DatumWriter<T> elementWriter, int bufferSize)
AvroArrayWriter(org.apache.avro.io.Encoder encoder, org.apache.avro.io.DatumWriter<T> elementWriter, Class<T> type, int bufferSize)	Deprecated. use the other constructor.

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush()
String	toString()
void	write(T t)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.spf4j.base.ArrayWriter

accept

Methods inherited from interface java.util.function.Consumer

andThen

Constructor Detail

AvroArrayWriter

@Deprecated
public AvroArrayWriter(org.apache.avro.io.Encoder encoder,
                       org.apache.avro.io.DatumWriter<T> elementWriter,
                       Class<T> type,
                       int bufferSize)

Deprecated.

use the other constructor.

AvroArrayWriter

public AvroArrayWriter(org.apache.avro.io.Encoder encoder,
                       org.apache.avro.io.DatumWriter<T> elementWriter,
                       int bufferSize)

Method Detail

write

public void write(T t)
           throws IOException

Specified by:

write in interface org.spf4j.base.ArrayWriter<T>

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface org.spf4j.base.ArrayWriter<T>

Specified by:

flush in interface Flushable

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface org.spf4j.base.ArrayWriter<T>

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object