org.apache.avro.ipc.reflect

Class ReflectRequestor

java.lang.Object

org.apache.avro.ipc.Requestor

org.apache.avro.ipc.specific.SpecificRequestor

org.apache.avro.ipc.reflect.ReflectRequestor

All Implemented Interfaces:

InvocationHandler

public class ReflectRequestor
extends SpecificRequestor

A Requestor for existing interfaces.

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

Constructors

Modifier	Constructor and Description
	ReflectRequestor(Class<?> iface, Transceiver transceiver)
	ReflectRequestor(Class<?> iface, Transceiver transceiver, ReflectData data)
protected	ReflectRequestor(Protocol protocol, Transceiver transceiver)
	ReflectRequestor(Protocol protocol, Transceiver transceiver, ReflectData data)

Method Summary

Methods

Modifier and Type	Method and Description
static <T> T	getClient(Class<T> iface, ReflectRequestor rreq) Create a proxy instance whose methods invoke RPCs.
static <T> T	getClient(Class<T> iface, Transceiver transciever) Create a proxy instance whose methods invoke RPCs.
static <T> T	getClient(Class<T> iface, Transceiver transciever, ReflectData reflectData) Create a proxy instance whose methods invoke RPCs.
protected DatumReader<Object>	getDatumReader(Schema writer, Schema reader)
protected DatumWriter<Object>	getDatumWriter(Schema schema)
ReflectData	getReflectData()

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

getClient, getClient, getDatumReader, getRemote, getSpecificData, invoke, readError, readResponse, writeRequest

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

addRPCPlugin, getLocal, getRemote, getTransceiver, readError, readResponse, request, 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

ReflectRequestor

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

Throws:

IOException

ReflectRequestor

public ReflectRequestor(Protocol protocol,
                Transceiver transceiver,
                ReflectData data)
                 throws IOException

Throws:

IOException

Method Detail

getReflectData

public ReflectData getReflectData()

getDatumWriter

protected DatumWriter<Object> getDatumWriter(Schema schema)

Overrides:

getDatumWriter in class SpecificRequestor

getDatumReader

protected DatumReader<Object> getDatumReader(Schema writer,
                                 Schema reader)

Overrides:

getDatumReader in class SpecificRequestor

getClient

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

Create a proxy instance whose methods invoke RPCs.

Throws:

IOException

getClient

public static <T> T getClient(Class<T> iface,
              Transceiver transciever,
              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