public abstract class GenericResponder extends Responder
Responder
implementation for generic Java data.rpcMetaPlugins
Constructor and Description |
---|
GenericResponder(org.apache.avro.Protocol local) |
GenericResponder(org.apache.avro.Protocol local,
org.apache.avro.generic.GenericData data) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.avro.io.DatumReader<Object> |
getDatumReader(org.apache.avro.Schema actual,
org.apache.avro.Schema expected) |
protected org.apache.avro.io.DatumWriter<Object> |
getDatumWriter(org.apache.avro.Schema schema) |
org.apache.avro.generic.GenericData |
getGenericData() |
Object |
readRequest(org.apache.avro.Schema actual,
org.apache.avro.Schema expected,
org.apache.avro.io.Decoder in)
Reads a request message.
|
void |
writeError(org.apache.avro.Schema schema,
Object error,
org.apache.avro.io.Encoder out)
Writes an error message.
|
void |
writeResponse(org.apache.avro.Schema schema,
Object response,
org.apache.avro.io.Encoder out)
Writes a response message.
|
public GenericResponder(org.apache.avro.Protocol local)
public GenericResponder(org.apache.avro.Protocol local, org.apache.avro.generic.GenericData data)
public org.apache.avro.generic.GenericData getGenericData()
protected org.apache.avro.io.DatumWriter<Object> getDatumWriter(org.apache.avro.Schema schema)
protected org.apache.avro.io.DatumReader<Object> getDatumReader(org.apache.avro.Schema actual, org.apache.avro.Schema expected)
public Object readRequest(org.apache.avro.Schema actual, org.apache.avro.Schema expected, org.apache.avro.io.Decoder in) throws IOException
Responder
readRequest
in class Responder
IOException
public void writeResponse(org.apache.avro.Schema schema, Object response, org.apache.avro.io.Encoder out) throws IOException
Responder
writeResponse
in class Responder
IOException
public void writeError(org.apache.avro.Schema schema, Object error, org.apache.avro.io.Encoder out) throws IOException
Responder
writeError
in class Responder
IOException
Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.