public class ReflectResponder extends SpecificResponder
Responder
for existing interfaces.rpcMetaPlugins
Constructor and Description |
---|
ReflectResponder(Class iface,
Object impl) |
ReflectResponder(Class iface,
Object impl,
ReflectData data) |
ReflectResponder(Protocol protocol,
Object impl) |
ReflectResponder(Protocol protocol,
Object impl,
ReflectData data) |
Modifier and Type | Method and Description |
---|---|
protected DatumReader<Object> |
getDatumReader(Schema actual,
Schema expected) |
protected DatumWriter<Object> |
getDatumWriter(Schema schema) |
ReflectData |
getReflectData() |
void |
writeError(Schema schema,
Object error,
Encoder out)
Writes an error message.
|
getSpecificData, respond
getGenericData, readRequest, writeResponse
public ReflectResponder(Class iface, Object impl, ReflectData data)
public ReflectResponder(Protocol protocol, Object impl, ReflectData data)
public ReflectData getReflectData()
protected DatumWriter<Object> getDatumWriter(Schema schema)
getDatumWriter
in class SpecificResponder
protected DatumReader<Object> getDatumReader(Schema actual, Schema expected)
getDatumReader
in class SpecificResponder
public void writeError(Schema schema, Object error, Encoder out) throws IOException
Responder
writeError
in class SpecificResponder
IOException
Copyright © 2009–2020 The Apache Software Foundation. All rights reserved.