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, respondgetGenericData, readRequest, writeResponsepublic 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 SpecificResponderprotected DatumReader<Object> getDatumReader(Schema actual, Schema expected)
getDatumReader in class SpecificResponderpublic void writeError(Schema schema, Object error, Encoder out) throws IOException
ResponderwriteError in class SpecificResponderIOExceptionCopyright © 2009–2020 The Apache Software Foundation. All rights reserved.