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,
org.apache.avro.reflect.ReflectData data) |
protected |
ReflectRequestor(org.apache.avro.Protocol protocol,
Transceiver transceiver) |
|
ReflectRequestor(org.apache.avro.Protocol protocol,
Transceiver transceiver,
org.apache.avro.reflect.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,
org.apache.avro.reflect.ReflectData reflectData)
Create a proxy instance whose methods invoke RPCs.
|
protected org.apache.avro.io.DatumReader<Object> |
getDatumReader(org.apache.avro.Schema writer,
org.apache.avro.Schema reader) |
protected org.apache.avro.io.DatumWriter<Object> |
getDatumWriter(org.apache.avro.Schema schema) |
org.apache.avro.reflect.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(org.apache.avro.Protocol protocol, Transceiver transceiver) throws IOException
IOException
public ReflectRequestor(Class<?> iface, Transceiver transceiver, org.apache.avro.reflect.ReflectData data) throws IOException
IOException
public ReflectRequestor(org.apache.avro.Protocol protocol, Transceiver transceiver, org.apache.avro.reflect.ReflectData data) throws IOException
IOException
public org.apache.avro.reflect.ReflectData getReflectData()
protected org.apache.avro.io.DatumWriter<Object> getDatumWriter(org.apache.avro.Schema schema)
getDatumWriter
in class SpecificRequestor
protected org.apache.avro.io.DatumReader<Object> getDatumReader(org.apache.avro.Schema writer, org.apache.avro.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, org.apache.avro.reflect.ReflectData reflectData) throws IOException
IOException
public static <T> T getClient(Class<T> iface, ReflectRequestor rreq) throws IOException
IOException
Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.