org.apache.avro.specific
Class SpecificRequestor

java.lang.Object
  extended by org.apache.avro.ipc.Requestor
      extended by org.apache.avro.reflect.ReflectRequestor
          extended by org.apache.avro.specific.SpecificRequestor
All Implemented Interfaces:
InvocationHandler

public class SpecificRequestor
extends ReflectRequestor

Requestor for generated interfaces.


Field Summary
 
Fields inherited from class org.apache.avro.ipc.Requestor
rpcMetaPlugins
 
Constructor Summary
SpecificRequestor(Class<?> iface, Transceiver transceiver)
           
SpecificRequestor(Class<?> iface, Transceiver transceiver, SpecificData specificData)
           
 
Method Summary
static Object getClient(Class<?> iface, SpecificRequestor requestor)
          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, SpecificData specificData)
          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.reflect.ReflectRequestor
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

SpecificRequestor

public SpecificRequestor(Class<?> iface,
                         Transceiver transceiver)
                  throws IOException
Throws:
IOException

SpecificRequestor

public SpecificRequestor(Class<?> iface,
                         Transceiver transceiver,
                         SpecificData specificData)
                  throws IOException
Throws:
IOException
Method Detail

getDatumWriter

protected DatumWriter<Object> getDatumWriter(Schema schema)
Overrides:
getDatumWriter in class ReflectRequestor

getDatumReader

protected DatumReader<Object> getDatumReader(Schema schema)
Overrides:
getDatumReader in class ReflectRequestor

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,
                               SpecificData specificData)
                        throws IOException
Create a proxy instance whose methods invoke RPCs.

Throws:
IOException

getClient

public static Object getClient(Class<?> iface,
                               SpecificRequestor requestor)
                        throws IOException
Create a proxy instance whose methods invoke RPCs.

Throws:
IOException


Copyright © 2009 The Apache Software Foundation