Package org.spf4j.avro.csv

Class CsvEncoder

java.lang.Object

org.apache.avro.io.Encoder

org.spf4j.avro.csv.CsvEncoder

All Implemented Interfaces:

Flushable, org.apache.avro.io.parsing.Parser.ActionHandler

public final class CsvEncoder
extends org.apache.avro.io.Encoder
implements org.apache.avro.io.parsing.Parser.ActionHandler

A Csv decoder for avro records.

Author:

Zoltan Farkas

Constructor Summary

Constructors

Constructor	Description
CsvEncoder(org.spf4j.io.csv.CsvWriter csvWriter, org.apache.avro.Schema writerSchema)

Method Summary

Modifier and Type	Method	Description
org.apache.avro.io.parsing.Symbol	doAction(org.apache.avro.io.parsing.Symbol symbol, org.apache.avro.io.parsing.Symbol symbol1)
void	flush()
void	setItemCount(long l)
void	startItem()
String	toString()
void	writeArrayEnd()
void	writeArrayStart()
void	writeBoolean(boolean bln)
void	writeBytes(byte[] bytes, int i, int length)
void	writeBytes(ByteBuffer bb)
void	writeDouble(double d)
void	writeEnum(int e)
void	writeFixed(byte[] bytes, int i, int length)
void	writeFloat(float f)
void	writeHeader()
void	writeIndex(int unionIndex)
void	writeInt(int i)
void	writeLong(long l)
void	writeMapEnd()
void	writeMapStart()
void	writeNull()
void	writeString(org.apache.avro.util.Utf8 utf8)

Methods inherited from class org.apache.avro.io.Encoder

writeBytes, writeFixed, writeFixed, writeString, writeString

Methods inherited from class java.lang.Object

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

Constructor Detail

CsvEncoder

public CsvEncoder(org.spf4j.io.csv.CsvWriter csvWriter,
                  org.apache.avro.Schema writerSchema)

Method Detail

writeHeader

public void writeHeader()
                 throws IOException

Throws:

IOException

writeNull

public void writeNull()
               throws IOException

Specified by:

writeNull in class org.apache.avro.io.Encoder

Throws:

IOException

writeBoolean

public void writeBoolean(boolean bln)
                  throws IOException

Specified by:

writeBoolean in class org.apache.avro.io.Encoder

Throws:

IOException

writeInt

public void writeInt(int i)
              throws IOException

Specified by:

writeInt in class org.apache.avro.io.Encoder

Throws:

IOException

writeLong

public void writeLong(long l)
               throws IOException

Specified by:

writeLong in class org.apache.avro.io.Encoder

Throws:

IOException

writeFloat

public void writeFloat(float f)
                throws IOException

Specified by:

writeFloat in class org.apache.avro.io.Encoder

Throws:

IOException

writeDouble

public void writeDouble(double d)
                 throws IOException

Specified by:

writeDouble in class org.apache.avro.io.Encoder

Throws:

IOException

writeString

public void writeString(org.apache.avro.util.Utf8 utf8)
                 throws IOException

Specified by:

writeString in class org.apache.avro.io.Encoder

Throws:

IOException

writeBytes

public void writeBytes(ByteBuffer bb)
                throws IOException

Specified by:

writeBytes in class org.apache.avro.io.Encoder

Throws:

IOException

writeBytes

public void writeBytes(byte[] bytes,
                       int i,
                       int length)
                throws IOException

Specified by:

writeBytes in class org.apache.avro.io.Encoder

Throws:

IOException

writeFixed

public void writeFixed(byte[] bytes,
                       int i,
                       int length)
                throws IOException

Specified by:

writeFixed in class org.apache.avro.io.Encoder

Throws:

IOException

writeEnum

public void writeEnum(int e)
               throws IOException

Specified by:

writeEnum in class org.apache.avro.io.Encoder

Throws:

IOException

writeArrayStart

public void writeArrayStart()
                     throws IOException

Specified by:

writeArrayStart in class org.apache.avro.io.Encoder

Throws:

IOException

writeArrayEnd

public void writeArrayEnd()
                   throws IOException

Specified by:

writeArrayEnd in class org.apache.avro.io.Encoder

Throws:

IOException

writeMapStart

public void writeMapStart()

Specified by:

writeMapStart in class org.apache.avro.io.Encoder

writeMapEnd

public void writeMapEnd()

Specified by:

writeMapEnd in class org.apache.avro.io.Encoder

writeIndex

public void writeIndex(int unionIndex)
                throws IOException

Specified by:

writeIndex in class org.apache.avro.io.Encoder

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Throws:

IOException

doAction

@Nullable
public org.apache.avro.io.parsing.Symbol doAction(org.apache.avro.io.parsing.Symbol symbol,
                                                  org.apache.avro.io.parsing.Symbol symbol1)

Specified by:

doAction in interface org.apache.avro.io.parsing.Parser.ActionHandler

setItemCount

public void setItemCount(long l)

Specified by:

setItemCount in class org.apache.avro.io.Encoder

startItem

public void startItem()
               throws IOException

Specified by:

startItem in class org.apache.avro.io.Encoder

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object