Package | Description |
---|---|
org.apache.avro |
Avro kernel classes.
|
org.apache.avro.grpc | |
org.apache.avro.ipc |
Support for inter-process calls.
|
org.apache.avro.ipc.specific |
Modifier and Type | Method and Description |
---|---|
Protocol.Message |
Protocol.createMessage(Protocol.Message m,
Schema request)
Create a one-way message using the
name , doc , and
props of m . |
Protocol.Message |
Protocol.createMessage(Protocol.Message m,
Schema request,
Schema response,
Schema errors)
Create a two-way message using the
name , doc , and
props of m . |
<T> Protocol.Message |
Protocol.createMessage(String name,
String doc,
JsonProperties propMap,
Schema request)
Create a one-way message.
|
<T> Protocol.Message |
Protocol.createMessage(String name,
String doc,
JsonProperties propMap,
Schema request,
Schema response,
Schema errors)
Create a two-way message.
|
<T> Protocol.Message |
Protocol.createMessage(String name,
String doc,
Map<String,?> propMap,
Schema request)
Create a one-way message.
|
<T> Protocol.Message |
Protocol.createMessage(String name,
String doc,
Map<String,?> propMap,
Schema request,
Schema response,
Schema errors)
Create a two-way message.
|
Protocol.Message |
Protocol.createMessage(String name,
String doc,
Schema request)
Deprecated.
|
Protocol.Message |
Protocol.createMessage(String name,
String doc,
Schema request,
Schema response,
Schema errors)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Map<String,Protocol.Message> |
Protocol.getMessages()
The messages of this protocol.
|
Modifier and Type | Method and Description |
---|---|
Protocol.Message |
Protocol.createMessage(Protocol.Message m,
Schema request)
Create a one-way message using the
name , doc , and
props of m . |
Protocol.Message |
Protocol.createMessage(Protocol.Message m,
Schema request,
Schema response,
Schema errors)
Create a two-way message using the
name , doc , and
props of m . |
Constructor and Description |
---|
AvroRequestMarshaller(Protocol.Message message) |
AvroResponseMarshaller(Protocol.Message message) |
Modifier and Type | Method and Description |
---|---|
Protocol.Message |
RPCContext.getMessage()
Returns the
Protocol.Message corresponding to this RPC |
Modifier and Type | Method and Description |
---|---|
abstract Object |
Responder.respond(Protocol.Message message,
Object request)
Computes the response for a message.
|
void |
RPCContext.setMessage(Protocol.Message message)
Sets the
Protocol.Message corresponding to this RPC |
Modifier and Type | Method and Description |
---|---|
Object |
SpecificResponder.respond(Protocol.Message message,
Object request) |
Copyright © 2009–2020 The Apache Software Foundation. All rights reserved.