org.apache.avro.ipc.reflect
Class ReflectRequestor

java.lang.Object
  extended by org.apache.avro.ipc.Requestor
      extended by org.apache.avro.ipc.specific.SpecificRequestor
          extended by 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
  ReflectRequestor(Class<?> iface, Transceiver transceiver)
           
protected ReflectRequestor(Protocol protocol, Transceiver transceiver)
           
 
Method Summary
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)
           
 
Methods inherited from class org.apache.avro.ipc.specific.SpecificRequestor
getClient, getClient, getDatumReader, getRemote, 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
Method Detail

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


Copyright © 2011 The Apache Software Foundation. All Rights Reserved.