Package | Description |
---|---|
org.apache.avro.data |
Interfaces and base classes shared by generic, specific and reflect.
|
org.apache.avro.generic |
A generic representation for Avro data.
|
org.apache.avro.io |
Utilities for Encoding and Decoding Avro data.
|
org.apache.avro.ipc |
Support for inter-process calls.
|
org.apache.avro.ipc.generic | |
org.apache.avro.ipc.specific | |
org.apache.avro.perf.test | |
org.apache.avro.protobuf |
Protocol Buffer
compatibility.
|
org.apache.avro.reflect |
Use Java reflection to generate schemas and protocols for existing
classes.
|
org.apache.avro.thrift |
Thrift compatibility.
|
Modifier and Type | Method and Description |
---|---|
Object |
Json.ObjectReader.read(Object reuse,
Decoder in) |
Modifier and Type | Method and Description |
---|---|
D |
GenericDatumReader.read(D reuse,
Decoder in) |
protected Object |
GenericDatumReader.readBytes(Object old,
Decoder in)
Called to read byte arrays.
|
protected Object |
GenericDatumReader.readBytes(Object old,
Schema s,
Decoder in)
Called to read byte arrays.
|
protected Object |
GenericDatumReader.readEnum(Schema expected,
Decoder in)
Called to read an enum value.
|
protected Object |
GenericDatumReader.readFixed(Object old,
Schema expected,
Decoder in)
Called to read a fixed value.
|
protected Object |
GenericDatumReader.readInt(Object old,
Schema expected,
Decoder in)
Called to read integers.
|
protected Object |
GenericDatumReader.readMapKey(Object old,
Schema expected,
Decoder in)
Called by the default implementation of
GenericDatumReader.readMap(java.lang.Object, org.apache.avro.Schema, org.apache.avro.io.ResolvingDecoder) to read a key value. |
protected Object |
GenericDatumReader.readString(Object old,
Decoder in)
Called to read strings.
|
protected Object |
GenericDatumReader.readString(Object old,
Schema expected,
Decoder in)
Called to read strings.
|
static void |
GenericDatumReader.skip(Schema schema,
Decoder in)
Skip an instance of a schema.
|
Modifier and Type | Class and Description |
---|---|
class |
BinaryDecoder
An
Decoder for binary-format data. |
class |
JsonDecoder
A
Decoder for Avro's JSON data encoding. |
class |
ParsingDecoder
|
class |
ResolvingDecoder
Decoder that performs type-resolution between the reader's and
writer's schemas. |
class |
ValidatingDecoder
An implementation of
Decoder that ensures that the sequence of
operations conforms to a schema. |
Modifier and Type | Field and Description |
---|---|
protected Decoder |
ValidatingDecoder.in |
Modifier and Type | Method and Description |
---|---|
ValidatingDecoder |
ValidatingDecoder.configure(Decoder in)
Re-initialize, reading from a new underlying Decoder.
|
void |
FastReaderBuilder.ExecutionStep.execute(Object record,
Decoder decoder) |
D |
DatumReader.read(D reuse,
Decoder in)
Read a datum.
|
Object |
FastReaderBuilder.FieldReader.read(Object reuse,
Decoder decoder) |
Object |
FastReaderBuilder.RecordReader.read(Object reuse,
Decoder decoder) |
Object |
FastReaderBuilder.MapReader.read(Object reuse,
Decoder decoder) |
ResolvingDecoder |
DecoderFactory.resolvingDecoder(Schema writer,
Schema reader,
Decoder wrapped)
Creates a
ResolvingDecoder wrapping the Decoder provided. |
ValidatingDecoder |
DecoderFactory.validatingDecoder(Schema schema,
Decoder wrapped)
Creates a
ValidatingDecoder wrapping the Decoder provided. |
Modifier and Type | Method and Description |
---|---|
Object |
Requestor.readError(Schema schema,
Decoder in)
Deprecated.
|
abstract Exception |
Requestor.readError(Schema writer,
Schema reader,
Decoder in)
Reads an error message.
|
abstract Object |
Responder.readRequest(Schema actual,
Schema expected,
Decoder in)
Reads a request message.
|
Object |
Requestor.readResponse(Schema schema,
Decoder in)
Deprecated.
|
abstract Object |
Requestor.readResponse(Schema writer,
Schema reader,
Decoder in)
Reads a response message.
|
Modifier and Type | Method and Description |
---|---|
Exception |
GenericRequestor.readError(Schema writer,
Schema reader,
Decoder in) |
Object |
GenericResponder.readRequest(Schema actual,
Schema expected,
Decoder in) |
Object |
GenericRequestor.readResponse(Schema writer,
Schema reader,
Decoder in) |
Modifier and Type | Method and Description |
---|---|
Exception |
SpecificRequestor.readError(Schema writer,
Schema reader,
Decoder in) |
Object |
SpecificRequestor.readResponse(Schema writer,
Schema reader,
Decoder in) |
Modifier and Type | Method and Description |
---|---|
protected Decoder |
BasicState.newDecoder(byte[] buf) |
Modifier and Type | Method and Description |
---|---|
protected Object |
ProtobufDatumReader.readBytes(Object old,
Decoder in) |
Modifier and Type | Method and Description |
---|---|
protected Date |
DateAsLongEncoding.read(Object reuse,
Decoder in) |
protected abstract T |
CustomEncoding.read(Object reuse,
Decoder in) |
protected Object |
ReflectDatumReader.readBytes(Object old,
Schema s,
Decoder in) |
protected Object |
ReflectDatumReader.readInt(Object old,
Schema expected,
Decoder in) |
protected Object |
ReflectDatumReader.readString(Object old,
Decoder in) |
Modifier and Type | Method and Description |
---|---|
protected Object |
ThriftDatumReader.readInt(Object old,
Schema s,
Decoder in) |
Copyright © 2009–2022 The Apache Software Foundation. All rights reserved.