Class ReflectResponder


public class ReflectResponder extends SpecificResponder
Responder for existing interfaces.
  • Constructor Details

    • ReflectResponder

      public ReflectResponder(Class iface, Object impl)
    • ReflectResponder

      public ReflectResponder(org.apache.avro.Protocol protocol, Object impl)
    • ReflectResponder

      public ReflectResponder(Class iface, Object impl, org.apache.avro.reflect.ReflectData data)
    • 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

      protected org.apache.avro.io.DatumWriter<Object> getDatumWriter(org.apache.avro.Schema schema)
      Overrides:
      getDatumWriter in class SpecificResponder
    • getDatumReader

      protected org.apache.avro.io.DatumReader<Object> getDatumReader(org.apache.avro.Schema actual, org.apache.avro.Schema expected)
      Overrides:
      getDatumReader in class SpecificResponder
    • 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.
      Overrides:
      writeError in class SpecificResponder
      Throws:
      IOException