public class ReflectRequestor extends SpecificRequestor
Requestor
for existing interfaces.Requestor.TransceiverCallback<T>
rpcMetaPlugins
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) |
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 transceiver)
Create a proxy instance whose methods invoke RPCs.
|
static <T> T |
getClient(Class<T> iface,
Transceiver transceiver,
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() |
getClient, getClient, getDatumReader, getRemote, getSpecificData, invoke, readError, readResponse, writeRequest
addRPCPlugin, getLocal, getRemote, getTransceiver, readError, readResponse, request, request
public ReflectRequestor(Class<?> iface, Transceiver transceiver) throws IOException
IOException
protected ReflectRequestor(Protocol protocol, Transceiver transceiver) throws IOException
IOException
public ReflectRequestor(Class<?> iface, Transceiver transceiver, ReflectData data) throws IOException
IOException
public ReflectRequestor(Protocol protocol, Transceiver transceiver, ReflectData data) throws IOException
IOException
public ReflectData getReflectData()
protected DatumWriter<Object> getDatumWriter(Schema schema)
getDatumWriter
in class SpecificRequestor
protected DatumReader<Object> getDatumReader(Schema writer, Schema reader)
getDatumReader
in class SpecificRequestor
public static <T> T getClient(Class<T> iface, Transceiver transceiver) throws IOException
IOException
public static <T> T getClient(Class<T> iface, Transceiver transceiver, ReflectData reflectData) throws IOException
IOException
public static <T> T getClient(Class<T> iface, ReflectRequestor rreq) throws IOException
IOException
Copyright © 2009–2022 The Apache Software Foundation. All rights reserved.