Package org.apache.avro.ipc.generic
Class GenericRequestor
java.lang.Object
org.apache.avro.ipc.Requestor
org.apache.avro.ipc.generic.GenericRequestor
Requestor implementation for generic Java data.-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.avro.ipc.Requestor
Requestor.TransceiverCallback<T> -
Field Summary
Fields inherited from class org.apache.avro.ipc.Requestor
rpcMetaPlugins -
Constructor Summary
ConstructorsConstructorDescriptionGenericRequestor(org.apache.avro.Protocol protocol, Transceiver transceiver) GenericRequestor(org.apache.avro.Protocol protocol, Transceiver transceiver, org.apache.avro.generic.GenericData data) -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.avro.generic.GenericDatareadError(org.apache.avro.Schema writer, org.apache.avro.Schema reader, org.apache.avro.io.Decoder in) Reads an error message.readResponse(org.apache.avro.Schema writer, org.apache.avro.Schema reader, org.apache.avro.io.Decoder in) Reads a response message.voidwriteRequest(org.apache.avro.Schema schema, Object request, org.apache.avro.io.Encoder out) Writes a request message.Methods inherited from class org.apache.avro.ipc.Requestor
addRPCPlugin, getLocal, getRemote, getTransceiver, readError, readResponse, request, request
-
Constructor Details
-
GenericRequestor
public GenericRequestor(org.apache.avro.Protocol protocol, Transceiver transceiver) throws IOException - Throws:
IOException
-
GenericRequestor
public GenericRequestor(org.apache.avro.Protocol protocol, Transceiver transceiver, org.apache.avro.generic.GenericData data) throws IOException - Throws:
IOException
-
-
Method Details
-
getGenericData
public org.apache.avro.generic.GenericData getGenericData() -
writeRequest
public void writeRequest(org.apache.avro.Schema schema, Object request, org.apache.avro.io.Encoder out) throws IOException Description copied from class:RequestorWrites a request message.- Specified by:
writeRequestin classRequestor- Throws:
IOException
-
readResponse
public Object readResponse(org.apache.avro.Schema writer, org.apache.avro.Schema reader, org.apache.avro.io.Decoder in) throws IOException Description copied from class:RequestorReads a response message.- Specified by:
readResponsein classRequestor- Throws:
IOException
-
readError
public Exception readError(org.apache.avro.Schema writer, org.apache.avro.Schema reader, org.apache.avro.io.Decoder in) throws IOException Description copied from class:RequestorReads an error message.- Specified by:
readErrorin classRequestor- Throws:
IOException
-