Package org.apache.avro.ipc.generic
Class GenericResponder
java.lang.Object
org.apache.avro.ipc.Responder
org.apache.avro.ipc.generic.GenericResponder
- Direct Known Subclasses:
SpecificResponder
Responder implementation for generic Java data.-
Field Summary
Fields inherited from class org.apache.avro.ipc.Responder
rpcMetaPlugins -
Constructor Summary
ConstructorsConstructorDescriptionGenericResponder(org.apache.avro.Protocol local) GenericResponder(org.apache.avro.Protocol local, org.apache.avro.generic.GenericData 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.generic.GenericDatareadRequest(org.apache.avro.Schema actual, org.apache.avro.Schema expected, org.apache.avro.io.Decoder in) Reads a request message.voidwriteError(org.apache.avro.Schema schema, Object error, org.apache.avro.io.Encoder out) Writes an error message.voidwriteResponse(org.apache.avro.Schema schema, Object response, org.apache.avro.io.Encoder out) Writes a response message.
-
Constructor Details
-
GenericResponder
public GenericResponder(org.apache.avro.Protocol local) -
GenericResponder
public GenericResponder(org.apache.avro.Protocol local, org.apache.avro.generic.GenericData data)
-
-
Method Details
-
getGenericData
public org.apache.avro.generic.GenericData getGenericData() -
getDatumWriter
-
getDatumReader
protected org.apache.avro.io.DatumReader<Object> getDatumReader(org.apache.avro.Schema actual, org.apache.avro.Schema expected) -
readRequest
public Object readRequest(org.apache.avro.Schema actual, org.apache.avro.Schema expected, org.apache.avro.io.Decoder in) throws IOException Description copied from class:ResponderReads a request message.- Specified by:
readRequestin classResponder- Throws:
IOException
-
writeResponse
public void writeResponse(org.apache.avro.Schema schema, Object response, org.apache.avro.io.Encoder out) throws IOException Description copied from class:ResponderWrites a response message.- Specified by:
writeResponsein classResponder- Throws:
IOException
-
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.- Specified by:
writeErrorin classResponder- Throws:
IOException
-