public abstract class Encoder extends Object implements Flushable
writeLong(long)
and
writeString(org.apache.avro.util.Utf8)
). These methods have analogs in Decoder
.
The other type of methods support the writing of maps and arrays.
These methods are writeArrayStart()
, startItem()
, and writeArrayEnd()
(and similar methods for
maps). Some implementations of Encoder
handle the
buffering required to break large maps and arrays into blocks,
which is necessary for applications that want to do streaming.
(See writeArrayStart()
for details on these methods.)
EncoderFactory
contains Encoder construction and configuration
facilities.EncoderFactory
,
Decoder
Constructor and Description |
---|
Encoder() |
Modifier and Type | Method and Description |
---|---|
abstract void |
setItemCount(long itemCount)
Call this method before writing a batch of items in an array or a map.
|
abstract void |
startItem()
Start a new item of an array or map.
|
abstract void |
writeArrayEnd()
Call this method to finish writing an array.
|
abstract void |
writeArrayStart()
Call this method to start writing an array.
|
abstract void |
writeBoolean(boolean b)
Write a boolean value.
|
void |
writeBytes(byte[] bytes)
Writes a byte string.
|
abstract void |
writeBytes(byte[] bytes,
int start,
int len)
Write a byte string.
|
abstract void |
writeBytes(ByteBuffer bytes)
Write a byte string.
|
abstract void |
writeDouble(double d)
Write a double.
|
abstract void |
writeEnum(int e)
Writes an enumeration.
|
void |
writeFixed(byte[] bytes)
A shorthand for writeFixed(bytes, 0, bytes.length)
|
abstract void |
writeFixed(byte[] bytes,
int start,
int len)
Writes a fixed size binary object.
|
void |
writeFixed(ByteBuffer bytes)
Writes a fixed from a ByteBuffer.
|
abstract void |
writeFloat(float f)
Write a float.
|
abstract void |
writeIndex(int unionIndex)
Call this method to write the tag of a union.
|
abstract void |
writeInt(int n)
Writes a 32-bit integer.
|
abstract void |
writeLong(long n)
Write a 64-bit integer.
|
abstract void |
writeMapEnd()
Call this method to terminate the inner-most, currently-opened
map.
|
abstract void |
writeMapStart()
Call this to start a new map.
|
abstract void |
writeNull()
"Writes" a null value.
|
void |
writeString(CharSequence charSequence)
Write a Unicode character string.
|
void |
writeString(String str)
Write a Unicode character string.
|
abstract void |
writeString(Utf8 utf8)
Write a Unicode character string.
|
public abstract void writeNull() throws IOException
AvroTypeException
- If this is a stateful writer and a
null is not expectedIOException
public abstract void writeBoolean(boolean b) throws IOException
AvroTypeException
- If this is a stateful writer and a
boolean is not expectedIOException
public abstract void writeInt(int n) throws IOException
AvroTypeException
- If this is a stateful writer and an
integer is not expectedIOException
public abstract void writeLong(long n) throws IOException
AvroTypeException
- If this is a stateful writer and a
long is not expectedIOException
public abstract void writeFloat(float f) throws IOException
IOException
AvroTypeException
- If this is a stateful writer and a
float is not expectedpublic abstract void writeDouble(double d) throws IOException
AvroTypeException
- If this is a stateful writer and a
double is not expectedIOException
public abstract void writeString(Utf8 utf8) throws IOException
AvroTypeException
- If this is a stateful writer and a
char-string is not expectedIOException
public void writeString(String str) throws IOException
Utf8
. Some Encoder
implementations may want to do something different as a performance optimization.AvroTypeException
- If this is a stateful writer and a
char-string is not expectedIOException
public void writeString(CharSequence charSequence) throws IOException
Utf8
it writes this directly, otherwise
the CharSequence is converted to a String via toString() and written.AvroTypeException
- If this is a stateful writer and a
char-string is not expectedIOException
public abstract void writeBytes(ByteBuffer bytes) throws IOException
AvroTypeException
- If this is a stateful writer and a
byte-string is not expectedIOException
public abstract void writeBytes(byte[] bytes, int start, int len) throws IOException
AvroTypeException
- If this is a stateful writer and a
byte-string is not expectedIOException
public void writeBytes(byte[] bytes) throws IOException
IOException
AvroTypeException
- If this is a stateful writer and a
byte-string is not expectedpublic abstract void writeFixed(byte[] bytes, int start, int len) throws IOException
bytes
- The contents to writestart
- The position within bytes where the contents
start.len
- The number of bytes to write.AvroTypeException
- If this is a stateful writer and a
byte-string is not expectedIOException
public void writeFixed(byte[] bytes) throws IOException
bytes
- IOException
public void writeFixed(ByteBuffer bytes) throws IOException
IOException
public abstract void writeEnum(int e) throws IOException
e
- AvroTypeException
- If this is a stateful writer and an enumeration
is not expected or the e is out of range.IOException
public abstract void writeArrayStart() throws IOException
writeArrayStart()
. Then, before writing any data for any item
call setItemCount(long)
followed by a sequence of
startItem()
and the item itself. The number of
startItem()
should match the number specified in
setItemCount(long)
.
When actually writing the data of the item, you can call any Encoder
method (e.g., writeLong(long)
). When all items
of the array have been written, call writeArrayEnd()
.
As an example, let's say you want to write an array of records,
the record consisting of an Long field and a Boolean field.
Your code would look something like this:
out.writeArrayStart(); out.setItemCount(list.size()); for (Record r : list) { out.startItem(); out.writeLong(r.longField); out.writeBoolean(r.boolField); } out.writeArrayEnd();
AvroTypeException
- If this is a stateful writer and an
array is not expectedIOException
public abstract void setItemCount(long itemCount) throws IOException
startItem()
followed by any of the
other write methods of Encoder
. The number of calls
to startItem()
must be equal to the count specified
in setItemCount(long)
. Once a batch is completed you
can start another batch with setItemCount(long)
.itemCount
- The number of startItem()
calls to follow.IOException
public abstract void startItem() throws IOException
writeArrayStart()
for usage information.AvroTypeException
- If called outside of an array or map contextIOException
public abstract void writeArrayEnd() throws IOException
writeArrayStart()
for usage information.AvroTypeException
- If items written does not match count
provided to writeArrayStart()
AvroTypeException
- If not currently inside an arrayIOException
public abstract void writeMapStart() throws IOException
writeArrayStart()
for details on usage.
As an example of usage, let's say you want to write a map of
records, the record consisting of an Long field and a Boolean
field. Your code would look something like this:
out.writeMapStart(); out.setItemCount(list.size()); for (Map.Entryentry : map.entrySet()) { out.startItem(); out.writeString(entry.getKey()); out.writeLong(entry.getValue().longField); out.writeBoolean(entry.getValue().boolField); } out.writeMapEnd();
AvroTypeException
- If this is a stateful writer and a
map is not expectedIOException
public abstract void writeMapEnd() throws IOException
writeArrayStart()
for more details.AvroTypeException
- If items written does not match count
provided to writeMapStart()
AvroTypeException
- If not currently inside a mapIOException
public abstract void writeIndex(int unionIndex) throws IOException
out.writeIndex(1); out.writeLong(record.longField); out.writeBoolean(record.boolField);
AvroTypeException
- If this is a stateful writer and a
map is not expectedIOException
Copyright © 2009–2017 The Apache Software Foundation. All rights reserved.