public Class ValidatingDecoder

Implements abstract org.apache.avro.io.Decoder.arrayNext.

Doc from org.apache.avro.io.Decoder.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.

Annotations

@Override

Re-initialize, reading from a new underlying Decoder.

Implements org.apache.avro.io.parsing.Parser.ActionHandler.doAction.

Doc from org.apache.avro.io.parsing.Parser.ActionHandler.doAction.

Handle the action symbol top when the input is sought to be taken off the stack.

Parameters

input:Symbol

The input symbol from the caller of advance

top:Symbol

The symbol at the top the stack.

Returns:Symbol

null if advance() is to continue processing the stack. If not null the return value will be returned by advance().

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.mapNext.

Doc from org.apache.avro.io.Decoder.mapNext.

Processes the next block of map entries and returns the count of them. Similar to arrayNext. See readMapStart for details.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readArrayStart.

Doc from org.apache.avro.io.Decoder.readArrayStart.

Reads and returns the size of the first block of an array. If this method returns non-zero, then the caller should read the indicated number of items, and then call 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;
    }
  }

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readBoolean.

Doc from org.apache.avro.io.Decoder.readBoolean.

Reads a boolean value written by Encoder#writeBoolean.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readBytes.

Doc from org.apache.avro.io.Decoder.readBytes.

Reads a byte-string written by Encoder#writeBytes. if old is not null and has sufficient capacity to take in the bytes being read, the bytes are returned in old.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readDouble.

Doc from org.apache.avro.io.Decoder.readDouble.

Reads a double written by Encoder#writeDouble.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readEnum.

Doc from org.apache.avro.io.Decoder.readEnum.

Reads an enumeration.

Returns:int

The enumeration's value.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readFixed.

Doc from org.apache.avro.io.Decoder.readFixed.

Reads fixed sized binary object.

Parameters

bytes:byte[]

The buffer to store the contents being read.

start:int

The position where the data needs to be written.

len:int

The size of the binary object.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readFloat.

Doc from org.apache.avro.io.Decoder.readFloat.

Reads a float written by Encoder#writeFloat.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readIndex.

Doc from org.apache.avro.io.Decoder.readIndex.

Reads the tag of a union written by Encoder#writeIndex.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readInt.

Doc from org.apache.avro.io.Decoder.readInt.

Reads an integer written by Encoder#writeInt.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readLong.

Doc from org.apache.avro.io.Decoder.readLong.

Reads a long written by Encoder#writeLong.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readMapStart.

Doc from org.apache.avro.io.Decoder.readMapStart.

Reads and returns the size of the next block of map-entries. Similar to 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:

Map m = 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);
  }
}

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readNull.

Doc from org.apache.avro.io.Decoder.readNull.

"Reads" a null value. (Doesn't actually read anything, but advances the state of the parser if the implementation is stateful.)

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readString.

Doc from org.apache.avro.io.Decoder.readString.

Reads a char-string written by Encoder#writeString.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.readString.

Doc from org.apache.avro.io.Decoder.readString.

Reads a char-string written by Encoder#writeString.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.skipArray.

Doc from org.apache.avro.io.Decoder.skipArray.

Used for quickly skipping through an array. Note you can either skip the entire array, or read the entire array (with 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;
    }
  }

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.skipBytes.

Doc from org.apache.avro.io.Decoder.skipBytes.

Discards a byte-string written by Encoder#writeBytes.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.skipFixed.

Doc from org.apache.avro.io.Decoder.skipFixed.

Discards fixed sized binary object.

Parameters

length:int

The size of the binary object to be skipped.

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.skipMap.

Doc from org.apache.avro.io.Decoder.skipMap.

Support for quickly skipping through a map similar to 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
  }
}

Annotations

@Override

Implements abstract org.apache.avro.io.Decoder.skipString.

Doc from org.apache.avro.io.Decoder.skipString.

Discards a char-string written by Encoder#writeString.

Annotations

@Override