Package org.apache.avro.ipc.specific
Class SpecificResponder
java.lang.Object
org.apache.avro.ipc.Responder
org.apache.avro.ipc.generic.GenericResponder
org.apache.avro.ipc.specific.SpecificResponder
- Direct Known Subclasses:
ReflectResponder
Responder for generated interfaces.-
Field Summary
Fields inherited from class org.apache.avro.ipc.Responder
rpcMetaPlugins -
Constructor Summary
ConstructorsConstructorDescriptionSpecificResponder(Class iface, Object impl) SpecificResponder(Class iface, Object impl, org.apache.avro.specific.SpecificData data) SpecificResponder(org.apache.avro.Protocol protocol, Object impl) SpecificResponder(org.apache.avro.Protocol protocol, Object impl, org.apache.avro.specific.SpecificData data) -
Method Summary
Modifier and TypeMethodDescriptionprotected org.apache.avro.io.DatumReader<Object> getDatumReader(org.apache.avro.Schema actual, org.apache.avro.Schema expected) protected org.apache.avro.io.DatumWriter<Object> getDatumWriter(org.apache.avro.Schema schema) org.apache.avro.specific.SpecificDataComputes the response for a message.voidwriteError(org.apache.avro.Schema schema, Object error, org.apache.avro.io.Encoder out) Writes an error message.Methods inherited from class org.apache.avro.ipc.generic.GenericResponder
getGenericData, readRequest, writeResponse
-
Constructor Details
-
SpecificResponder
-
SpecificResponder
-
SpecificResponder
-
SpecificResponder
public SpecificResponder(org.apache.avro.Protocol protocol, Object impl, org.apache.avro.specific.SpecificData data)
-
-
Method Details
-
getSpecificData
public org.apache.avro.specific.SpecificData getSpecificData() -
getDatumWriter
- Overrides:
getDatumWriterin classGenericResponder
-
getDatumReader
protected org.apache.avro.io.DatumReader<Object> getDatumReader(org.apache.avro.Schema actual, org.apache.avro.Schema expected) - Overrides:
getDatumReaderin classGenericResponder
-
writeError
public void writeError(org.apache.avro.Schema schema, Object error, org.apache.avro.io.Encoder out) throws IOException Description copied from class:ResponderWrites an error message.- Overrides:
writeErrorin classGenericResponder- Throws:
IOException
-
respond
Description copied from class:ResponderComputes the response for a message.
-