org.apache.avro.reflect
Class ReflectResponder

java.lang.Object
  extended by org.apache.avro.ipc.Responder
      extended by org.apache.avro.specific.SpecificResponder
          extended by org.apache.avro.reflect.ReflectResponder

public class ReflectResponder
extends SpecificResponder

Responder for existing interfaces.


Field Summary
 
Fields inherited from class org.apache.avro.ipc.Responder
rpcMetaPlugins
 
Constructor Summary
ReflectResponder(Class iface, Object impl)
           
ReflectResponder(Protocol protocol, Object impl)
           
 
Method Summary
protected  DatumReader<Object> getDatumReader(Schema schema)
           
protected  DatumWriter<Object> getDatumWriter(Schema schema)
           
 void writeError(Schema schema, Object error, Encoder out)
          Writes an error message.
 
Methods inherited from class org.apache.avro.specific.SpecificResponder
readRequest, respond, writeResponse
 
Methods inherited from class org.apache.avro.ipc.Responder
addRPCPlugin, getLocal, respond, respond
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ReflectResponder

public ReflectResponder(Class iface,
                        Object impl)

ReflectResponder

public ReflectResponder(Protocol protocol,
                        Object impl)
Method Detail

getDatumWriter

protected DatumWriter<Object> getDatumWriter(Schema schema)
Overrides:
getDatumWriter in class SpecificResponder

getDatumReader

protected DatumReader<Object> getDatumReader(Schema schema)
Overrides:
getDatumReader in class SpecificResponder

writeError

public void writeError(Schema schema,
                       Object error,
                       Encoder out)
                throws IOException
Description copied from class: Responder
Writes an error message.

Overrides:
writeError in class SpecificResponder
Throws:
IOException


Copyright © 2010 The Apache Software Foundation