public class ValidatingDecoder extends ParsingDecoder implements Parser.ActionHandler
Decoder
that ensures that the sequence of
operations conforms to a schema.
Use DecoderFactory.validatingDecoder(Schema, Decoder)
to construct
and configure.
ValidatingDecoder is not thread-safe.Decoder
,
DecoderFactory
Modifier and Type | Field and Description |
---|---|
protected Decoder |
in |
parser
Modifier and Type | Method and Description |
---|---|
long |
arrayNext()
Processes the next block of an array and returns the number of items in the
block and let's the caller read those items.
|
ValidatingDecoder |
configure(Decoder in)
Re-initialize, reading from a new underlying Decoder.
|
Symbol |
doAction(Symbol input,
Symbol top)
Handle the action symbol top when the input is sought to be
taken off the stack.
|
long |
mapNext()
Processes the next block of map entries and returns the count of them.
|
long |
readArrayStart()
Reads and returns the size of the first block of an array.
|
boolean |
readBoolean()
Reads a boolean value written by
Encoder.writeBoolean(boolean) . |
ByteBuffer |
readBytes(ByteBuffer old)
Reads a byte-string written by
Encoder.writeBytes(java.nio.ByteBuffer) . |
double |
readDouble()
Reads a double written by
Encoder.writeDouble(double) . |
int |
readEnum()
Reads an enumeration.
|
void |
readFixed(byte[] bytes,
int start,
int len)
Reads fixed sized binary object.
|
float |
readFloat()
Reads a float written by
Encoder.writeFloat(float) . |
int |
readIndex()
Reads the tag of a union written by
Encoder.writeIndex(int) . |
int |
readInt()
Reads an integer written by
Encoder.writeInt(int) . |
long |
readLong()
Reads a long written by
Encoder.writeLong(long) . |
long |
readMapStart()
Reads and returns the size of the next block of map-entries.
|
void |
readNull()
"Reads" a null value.
|
String |
readString()
Reads a char-string written by
Encoder.writeString(org.apache.avro.util.Utf8) . |
Utf8 |
readString(Utf8 old)
Reads a char-string written by
Encoder.writeString(org.apache.avro.util.Utf8) . |
long |
skipArray()
Used for quickly skipping through an array.
|
void |
skipBytes()
Discards a byte-string written by
Encoder.writeBytes(java.nio.ByteBuffer) . |
protected void |
skipFixed() |
void |
skipFixed(int length)
Discards fixed sized binary object.
|
long |
skipMap()
Support for quickly skipping through a map similar to
Decoder.skipArray() . |
void |
skipString()
Discards a char-string written by
Encoder.writeString(org.apache.avro.util.Utf8) . |
skipAction, skipTopSymbol
protected Decoder in
public ValidatingDecoder configure(Decoder in) throws IOException
IOException
public void readNull() throws IOException
Decoder
readNull
in class Decoder
IOException
public boolean readBoolean() throws IOException
Decoder
Encoder.writeBoolean(boolean)
.readBoolean
in class Decoder
IOException
public int readInt() throws IOException
Decoder
Encoder.writeInt(int)
.readInt
in class Decoder
IOException
public long readLong() throws IOException
Decoder
Encoder.writeLong(long)
.readLong
in class Decoder
IOException
public float readFloat() throws IOException
Decoder
Encoder.writeFloat(float)
.readFloat
in class Decoder
IOException
public double readDouble() throws IOException
Decoder
Encoder.writeDouble(double)
.readDouble
in class Decoder
IOException
public Utf8 readString(Utf8 old) throws IOException
Decoder
Encoder.writeString(org.apache.avro.util.Utf8)
.readString
in class Decoder
IOException
public String readString() throws IOException
Decoder
Encoder.writeString(org.apache.avro.util.Utf8)
.readString
in class Decoder
IOException
public void skipString() throws IOException
Decoder
Encoder.writeString(org.apache.avro.util.Utf8)
.skipString
in class Decoder
IOException
public ByteBuffer readBytes(ByteBuffer old) throws IOException
Decoder
Encoder.writeBytes(java.nio.ByteBuffer)
. if old is
not null and has sufficient capacity to take in the bytes being read, the
bytes are returned in old.readBytes
in class Decoder
IOException
public void skipBytes() throws IOException
Decoder
Encoder.writeBytes(java.nio.ByteBuffer)
.skipBytes
in class Decoder
IOException
public void readFixed(byte[] bytes, int start, int len) throws IOException
Decoder
readFixed
in class Decoder
bytes
- The buffer to store the contents being read.start
- The position where the data needs to be written.len
- The size of the binary object.IOException
public void skipFixed(int length) throws IOException
Decoder
skipFixed
in class Decoder
length
- The size of the binary object to be skipped.IOException
protected void skipFixed() throws IOException
skipFixed
in class ParsingDecoder
IOException
public int readEnum() throws IOException
Decoder
readEnum
in class Decoder
IOException
public long readArrayStart() throws IOException
Decoder
Decoder.arrayNext()
to find out the number of items in the next
block. The typical pattern for consuming an array looks like:
for(long i = in.readArrayStart(); i != 0; i = in.arrayNext()) { for (long j = 0; j < i; j++) { read next element of the array; } }
readArrayStart
in class Decoder
IOException
public long arrayNext() throws IOException
Decoder
arrayNext
in class Decoder
IOException
public long skipArray() throws IOException
Decoder
Decoder.readArrayStart()
), but
you can't mix the two on the same array.
This method will skip through as many items as it can, all of them if
possible. It will return zero if there are no more items to skip through, or
an item count if it needs the client's help in skipping. The typical usage
pattern is:
for(long i = in.skipArray(); i != 0; i = i.skipArray()) { for (long j = 0; j < i; j++) { read and discard the next element of the array; } }Note that this method can automatically skip through items if a byte-count is found in the underlying data, or if a schema has been provided to the implementation, but otherwise the client will have to skip through items itself.
skipArray
in class Decoder
IOException
public long readMapStart() throws IOException
Decoder
Decoder.readArrayStart()
.
As an example, let's say you want to read a map of records, the record
consisting of an Long field and a Boolean field. Your code would look
something like this:
Mapm = new HashMap (); Record reuse = new Record(); for (long i = in.readMapStart(); i != 0; i = in.readMapNext()) { for (long j = 0; j < i; j++) { String key = in.readString(); reuse.intField = in.readInt(); reuse.boolField = in.readBoolean(); m.put(key, reuse); } }
readMapStart
in class Decoder
IOException
public long mapNext() throws IOException
Decoder
Decoder.arrayNext()
. See Decoder.readMapStart()
for details.mapNext
in class Decoder
IOException
public long skipMap() throws IOException
Decoder
Decoder.skipArray()
.
As an example, let's say you want to skip a map of records, the record
consisting of an Long field and a Boolean field. Your code would look
something like this:
for (long i = in.skipMap(); i != 0; i = in.skipMap()) { for (long j = 0; j < i; j++) { in.skipString(); // Discard key in.readInt(); // Discard int-field of value in.readBoolean(); // Discard boolean-field of value } }
skipMap
in class Decoder
IOException
public int readIndex() throws IOException
Decoder
Encoder.writeIndex(int)
.readIndex
in class Decoder
IOException
public Symbol doAction(Symbol input, Symbol top) throws IOException
Parser.ActionHandler
doAction
in interface Parser.ActionHandler
input
- The input symbol from the caller of advancetop
- The symbol at the top the stack.IOException
Copyright © 2009–2020 The Apache Software Foundation. All rights reserved.