org.apache.avro.specific
Class SpecificRequestor

java.lang.Object
  org.apache.avro.ipc.Requestor
      org.apache.avro.reflect.ReflectRequestor
          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.reflect.ReflectRequestor

packageName

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