public class ReflectRequestor extends SpecificRequestor
Requestor for existing interfaces.Requestor.TransceiverCallback<T>rpcMetaPlugins| Modifier | Constructor and Description |
|---|---|
|
ReflectRequestor(Class<?> iface,
Transceiver transceiver) |
protected |
ReflectRequestor(Protocol protocol,
Transceiver transceiver) |
| 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) |
getClient, getClient, getDatumReader, getRemote, invoke, readError, readResponse, writeRequestaddRPCPlugin, getLocal, getRemote, getTransceiver, readError, readResponse, request, requestpublic ReflectRequestor(Class<?> iface, Transceiver transceiver) throws IOException
IOExceptionprotected ReflectRequestor(Protocol protocol, Transceiver transceiver) throws IOException
IOExceptionprotected DatumWriter<Object> getDatumWriter(Schema schema)
getDatumWriter in class SpecificRequestorprotected DatumReader<Object> getDatumReader(Schema writer, Schema reader)
getDatumReader in class SpecificRequestorpublic static <T> T getClient(Class<T> iface, Transceiver transciever) throws IOException
IOExceptionpublic static <T> T getClient(Class<T> iface, Transceiver transciever, ReflectData reflectData) throws IOException
IOExceptionpublic static <T> T getClient(Class<T> iface, ReflectRequestor rreq) throws IOException
IOExceptionCopyright © 2009-2012 The Apache Software Foundation. All Rights Reserved.