Class ReflectRequestor

All Implemented Interfaces:
InvocationHandler

public class ReflectRequestor extends SpecificRequestor
A Requestor for existing interfaces.
  • Constructor Details

  • 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 SpecificRequestor
    • getDatumReader

      protected org.apache.avro.io.DatumReader<Object> getDatumReader(org.apache.avro.Schema writer, org.apache.avro.Schema reader)
      Overrides:
      getDatumReader in class SpecificRequestor
    • getClient

      public static <T> T getClient(Class<T> iface, Transceiver transceiver) throws IOException
      Create a proxy instance whose methods invoke RPCs.
      Throws:
      IOException
    • getClient

      public static <T> T getClient(Class<T> iface, Transceiver transceiver, org.apache.avro.reflect.ReflectData reflectData) throws IOException
      Create a proxy instance whose methods invoke RPCs.
      Throws:
      IOException
    • getClient

      public static <T> T getClient(Class<T> iface, ReflectRequestor rreq) throws IOException
      Create a proxy instance whose methods invoke RPCs.
      Throws:
      IOException