Class GenericResponder

java.lang.Object
org.apache.avro.ipc.Responder
org.apache.avro.ipc.generic.GenericResponder
Direct Known Subclasses:
SpecificResponder

public abstract class GenericResponder extends Responder
Responder implementation for generic Java data.
  • 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

      protected org.apache.avro.io.DatumWriter<Object> getDatumWriter(org.apache.avro.Schema schema)
    • 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: Responder
      Reads a request message.
      Specified by:
      readRequest in class Responder
      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: Responder
      Writes a response message.
      Specified by:
      writeResponse in class Responder
      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: Responder
      Writes an error message.
      Specified by:
      writeError in class Responder
      Throws:
      IOException