Package org.apache.avro.ipc.reflect
Class ReflectResponder
java.lang.Object
org.apache.avro.ipc.Responder
org.apache.avro.ipc.generic.GenericResponder
org.apache.avro.ipc.specific.SpecificResponder
org.apache.avro.ipc.reflect.ReflectResponder
Responder for existing interfaces.-
Field Summary
Fields inherited from class org.apache.avro.ipc.Responder
rpcMetaPlugins -
Constructor Summary
ConstructorsConstructorDescriptionReflectResponder(Class iface, Object impl) ReflectResponder(Class iface, Object impl, org.apache.avro.reflect.ReflectData data) ReflectResponder(org.apache.avro.Protocol protocol, Object impl) ReflectResponder(org.apache.avro.Protocol protocol, Object impl, org.apache.avro.reflect.ReflectData 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.reflect.ReflectDatavoidwriteError(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.specific.SpecificResponder
getSpecificData, respondMethods inherited from class org.apache.avro.ipc.generic.GenericResponder
getGenericData, readRequest, writeResponse
-
Constructor Details
-
ReflectResponder
-
ReflectResponder
-
ReflectResponder
-
ReflectResponder
public ReflectResponder(org.apache.avro.Protocol protocol, Object impl, org.apache.avro.reflect.ReflectData data)
-
-
Method Details
-
getReflectData
public org.apache.avro.reflect.ReflectData getReflectData() -
getDatumWriter
- Overrides:
getDatumWriterin classSpecificResponder
-
getDatumReader
protected org.apache.avro.io.DatumReader<Object> getDatumReader(org.apache.avro.Schema actual, org.apache.avro.Schema expected) - Overrides:
getDatumReaderin classSpecificResponder
-
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 classSpecificResponder- Throws:
IOException
-