public class SpecificResponder extends GenericResponder
Responder
for generated interfaces.rpcMetaPlugins
Constructor and Description |
---|
SpecificResponder(Class iface,
Object impl) |
SpecificResponder(Class iface,
Object impl,
org.apache.avro.specific.SpecificData data) |
SpecificResponder(org.apache.avro.Protocol protocol,
Object impl) |
SpecificResponder(org.apache.avro.Protocol protocol,
Object impl,
org.apache.avro.specific.SpecificData 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.specific.SpecificData |
getSpecificData() |
Object |
respond(org.apache.avro.Protocol.Message message,
Object request)
Computes the response for a message.
|
void |
writeError(org.apache.avro.Schema schema,
Object error,
org.apache.avro.io.Encoder out)
Writes an error message.
|
getGenericData, readRequest, writeResponse
public SpecificResponder(org.apache.avro.Protocol protocol, Object impl)
public SpecificResponder(Class iface, Object impl, org.apache.avro.specific.SpecificData data)
public SpecificResponder(org.apache.avro.Protocol protocol, Object impl, org.apache.avro.specific.SpecificData data)
public org.apache.avro.specific.SpecificData getSpecificData()
protected org.apache.avro.io.DatumWriter<Object> getDatumWriter(org.apache.avro.Schema schema)
getDatumWriter
in class GenericResponder
protected org.apache.avro.io.DatumReader<Object> getDatumReader(org.apache.avro.Schema actual, org.apache.avro.Schema expected)
getDatumReader
in class GenericResponder
public void writeError(org.apache.avro.Schema schema, Object error, org.apache.avro.io.Encoder out) throws IOException
Responder
writeError
in class GenericResponder
IOException
Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.