public class BinaryMessageDecoder<D> extends MessageDecoder.BaseDecoder<D>
MessageDecoder that reads a binary-encoded datum. This checks for
the datum header and decodes the payload with the schema that corresponds to
the 8-byte schema fingerprint.
Instances can decode message payloads for known schemas, which
are schemas added using addSchema(Schema), schemas resolved by the
SchemaStore passed to the constructor, or the expected schema passed
to the constructor. Messages encoded using an unknown schema will cause
instances to throw a MissingSchemaException.
It is safe to continue using instances of this class after decode(java.io.InputStream, D)
throws BadHeaderException or MissingSchemaException.
This class is thread-safe.
MessageDecoder.BaseDecoder<D>| Constructor and Description |
|---|
BinaryMessageDecoder(GenericData model,
Schema readSchema)
Creates a new
BinaryMessageEncoder that uses the given
data model to construct datum instances described by
the schema. |
BinaryMessageDecoder(GenericData model,
Schema readSchema,
SchemaStore resolver)
Creates a new
BinaryMessageEncoder that uses the given
data model to construct datum instances described by
the schema. |
| Modifier and Type | Method and Description |
|---|---|
void |
addSchema(Schema writeSchema)
Adds a
Schema that can be used to decode buffers. |
D |
decode(InputStream stream,
D reuse)
Deserialize a single datum from an InputStream.
|
public BinaryMessageDecoder(GenericData model, Schema readSchema)
BinaryMessageEncoder that uses the given
data model to construct datum instances described by
the schema.
The readSchema is as used the expected schema (read schema). Datum
instances created by this class will are described by the expected schema.
The schema used to decode incoming buffers is determined by the schema
fingerprint encoded in the message header. This class can decode messages
that were encoded using the readSchema and other schemas that are
added using addSchema(Schema).
model - the data model for datum instancesreadSchema - the Schema used to construct datum instancespublic BinaryMessageDecoder(GenericData model, Schema readSchema, SchemaStore resolver)
BinaryMessageEncoder that uses the given
data model to construct datum instances described by
the schema.
The readSchema is used as the expected schema (read schema). Datum
instances created by this class will are described by the expected schema.
The schema used to decode incoming buffers is determined by the schema
fingerprint encoded in the message header. This class can decode messages
that were encoded using the readSchema, other schemas that are
added using addSchema(Schema), or schemas returned by the
resolver.
model - the data model for datum instancesreadSchema - the Schema used to construct datum instancesresolver - a SchemaStore used to find schemas by fingerprintpublic void addSchema(Schema writeSchema)
Schema that can be used to decode buffers.writeSchema - a Schema to use when decoding bufferspublic D decode(InputStream stream, D reuse) throws IOException
MessageDecoderstream - stream to read fromreuse - a datum instance to reuse, avoiding instantiation if possibleIOExceptionCopyright © 2009–2017 The Apache Software Foundation. All rights reserved.