org.apache.avro.reflect
Class ReflectRequestor

java.lang.Object
  org.apache.avro.ipc.Requestor
      org.apache.avro.specific.SpecificRequestor
          org.apache.avro.reflect.ReflectRequestor

All Implemented Interfaces:

InvocationHandler

public class ReflectRequestor
extends SpecificRequestor

A Requestor for existing interfaces.

Field Summary

Fields inherited from class org.apache.avro.ipc.Requestor

rpcMetaPlugins

Constructor Summary

	ReflectRequestor(Class<?> iface, Transceiver transceiver)
protected	ReflectRequestor(Protocol protocol, Transceiver transceiver)

Method Summary

static Object	getClient(Class<?> iface, ReflectRequestor rreq) Create a proxy instance whose methods invoke RPCs.
static Object	getClient(Class<?> iface, Transceiver transciever) Create a proxy instance whose methods invoke RPCs.
static Object	getClient(Class<?> iface, Transceiver transciever, ReflectData reflectData) Create a proxy instance whose methods invoke RPCs.
protected DatumReader<Object>	getDatumReader(Schema schema)
protected DatumWriter<Object>	getDatumWriter(Schema schema)

Methods inherited from class org.apache.avro.specific.SpecificRequestor

getClient, getClient, invoke, readError, readResponse, writeRequest

Methods inherited from class org.apache.avro.ipc.Requestor

addRPCPlugin, getLocal, getRemote, getTransceiver, request

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReflectRequestor

public ReflectRequestor(Class<?> iface,
                        Transceiver transceiver)
                 throws IOException

Throws:

IOException

ReflectRequestor

protected ReflectRequestor(Protocol protocol,
                           Transceiver transceiver)
                    throws IOException

Throws:

IOException

Method Detail

getDatumWriter

protected DatumWriter<Object> getDatumWriter(Schema schema)

Overrides:

getDatumWriter in class SpecificRequestor

getDatumReader

protected DatumReader<Object> getDatumReader(Schema schema)

Overrides:

getDatumReader in class SpecificRequestor

getClient

public static Object getClient(Class<?> iface,
                               Transceiver transciever)
                        throws IOException

Create a proxy instance whose methods invoke RPCs.

Throws:

IOException

getClient

public static Object getClient(Class<?> iface,
                               Transceiver transciever,
                               ReflectData reflectData)
                        throws IOException

Create a proxy instance whose methods invoke RPCs.

Throws:

IOException

getClient

public static Object getClient(Class<?> iface,
                               ReflectRequestor rreq)
                        throws IOException

Create a proxy instance whose methods invoke RPCs.

Throws:

IOException