Skip navigation links
A B C D E F G H I J L M N O P R S T U V W 

A

addConnector(Connector) - Method in class org.apache.avro.ipc.HttpServer
 
addRPCPlugin(RPCPlugin) - Method in class org.apache.avro.ipc.Requestor
Adds a new plugin to manipulate RPC metadata.
addRPCPlugin(RPCPlugin) - Method in class org.apache.avro.ipc.Responder
Adds a new plugin to manipulate per-call metadata.
await() - Method in class org.apache.avro.ipc.CallFuture
Waits for the CallFuture to complete without returning the result.
await(long, TimeUnit) - Method in class org.apache.avro.ipc.CallFuture
Waits for the CallFuture to complete without returning the result.

B

build() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
 
build() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
 
buildDefaultBootstrapOptions(Long) - Static method in class org.apache.avro.ipc.NettyTransceiver
Creates the default options map for the Netty ClientBootstrap.

C

Callback<T> - Interface in org.apache.avro.ipc
Interface for receiving asynchronous callbacks.
callback - Variable in class org.apache.avro.ipc.NettyTransceiver.WriteFutureListener
 
CallFuture<T> - Class in org.apache.avro.ipc
A Future implementation for RPCs.
CallFuture() - Constructor for class org.apache.avro.ipc.CallFuture
Creates a CallFuture.
CallFuture(Callback<T>) - Constructor for class org.apache.avro.ipc.CallFuture
Creates a CallFuture with a chained Callback which will be invoked when this CallFuture's Callback methods are invoked.
cancel(boolean) - Method in class org.apache.avro.ipc.CallFuture
 
channelOpen(ChannelHandlerContext, ChannelStateEvent) - Method in class org.apache.avro.ipc.NettyTransceiver.NettyClientAvroHandler
 
charts - Variable in class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
 
clearClientHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Clears the value of the 'clientHash' field.
clearClientProtocol() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Clears the value of the 'clientProtocol' field.
clearMatch() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Clears the value of the 'match' field.
clearMeta() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Clears the value of the 'meta' field.
clearMeta() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Clears the value of the 'meta' field.
clearServerHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Clears the value of the 'serverHash' field.
clearServerHash() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Clears the value of the 'serverHash' field.
clearServerProtocol() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Clears the value of the 'serverProtocol' field.
clientFinishConnect(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
Called on the client after the initial RPC handshake
clientHash - Variable in class org.apache.avro.ipc.HandshakeRequest
Deprecated.
clientProtocol - Variable in class org.apache.avro.ipc.HandshakeRequest
Deprecated.
clientReceiveResponse(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
This method is invoked at the client after the call is executed, and after the client receives the response
clientReceiveResponse(RPCContext) - Method in class org.apache.avro.ipc.stats.StatsPlugin
 
clientSendRequest(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
This method is invoked at the client before it issues the RPC call.
clientSendRequest(RPCContext) - Method in class org.apache.avro.ipc.stats.StatsPlugin
 
clientStartConnect(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
Called on the client before the initial RPC handshake to setup any handshake metadata for this plugin
close() - Method in class org.apache.avro.ipc.DatagramServer
 
close() - Method in class org.apache.avro.ipc.HttpServer
 
close() - Method in class org.apache.avro.ipc.NettyServer
 
close() - Method in class org.apache.avro.ipc.NettyTransceiver
Closes this transceiver and disconnects from the remote peer.
close(boolean) - Method in class org.apache.avro.ipc.NettyTransceiver
Closes this transceiver and disconnects from the remote peer.
close() - Method in class org.apache.avro.ipc.SaslSocketTransceiver
 
close() - Method in interface org.apache.avro.ipc.Server
Stop this server.
close() - Method in class org.apache.avro.ipc.SocketServer
Deprecated.
 
close() - Method in class org.apache.avro.ipc.SocketTransceiver
Deprecated.
 
close() - Method in class org.apache.avro.ipc.Transceiver
 
createDecoder(SchemaStore) - Static method in class org.apache.avro.ipc.HandshakeRequest
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.
createDecoder(SchemaStore) - Static method in class org.apache.avro.ipc.HandshakeResponse
Create a new BinaryMessageDecoder instance for this class that uses the specified SchemaStore.
createNettyClientAvroHandler() - Method in class org.apache.avro.ipc.NettyTransceiver
Creates a Netty ChannelUpstreamHandler for handling events on the Netty client channel.
createServer(Responder, URI) - Static method in class org.apache.avro.ipc.Ipc
Create a Server listening at the named URI using the provided responder.
createTransceiver(URI) - Static method in class org.apache.avro.ipc.Ipc
Create a client Transceiver connecting to the provided URI.

D

DatagramServer - Class in org.apache.avro.ipc
A datagram-based server implementation.
DatagramServer(Responder, SocketAddress) - Constructor for class org.apache.avro.ipc.DatagramServer
 
DatagramTransceiver - Class in org.apache.avro.ipc
A datagram-based Transceiver implementation.
DatagramTransceiver(SocketAddress) - Constructor for class org.apache.avro.ipc.DatagramTransceiver
 
DatagramTransceiver(DatagramChannel) - Constructor for class org.apache.avro.ipc.DatagramTransceiver
 
decode(ChannelHandlerContext, Channel, ChannelBuffer) - Method in class org.apache.avro.ipc.NettyTransportCodec.NettyFrameDecoder
decode buffer to NettyDataPack
DEFAULT_CONNECTION_TIMEOUT_MILLIS - Static variable in class org.apache.avro.ipc.NettyTransceiver
If not specified, the default connection timeout will be used (60 sec).
DEFAULT_TCP_NODELAY_VALUE - Static variable in class org.apache.avro.ipc.NettyTransceiver
 
doGet(HttpServletRequest, HttpServletResponse) - Method in class org.apache.avro.ipc.stats.StatsServlet
 
doPost(HttpServletRequest, HttpServletResponse) - Method in class org.apache.avro.ipc.ResponderServlet
 

E

encode(ChannelHandlerContext, Channel, Object) - Method in class org.apache.avro.ipc.NettyTransportCodec.NettyFrameEncoder
encode msg to ChannelBuffer
error - Variable in class org.apache.avro.ipc.RPCContext
 
error() - Method in class org.apache.avro.ipc.RPCContext
The exception generated at the server, or null if no such exception has occured
escapeStringArray(List<String>) - Static method in class org.apache.avro.ipc.stats.StatsServlet
 
exceptionCaught(ChannelHandlerContext, ExceptionEvent) - Method in class org.apache.avro.ipc.NettyTransceiver.NettyClientAvroHandler
 

F

fromByteBuffer(ByteBuffer) - Static method in class org.apache.avro.ipc.HandshakeRequest
Deserializes a HandshakeRequest from a ByteBuffer.
fromByteBuffer(ByteBuffer) - Static method in class org.apache.avro.ipc.HandshakeResponse
Deserializes a HandshakeResponse from a ByteBuffer.

G

GenericRequestor - Class in org.apache.avro.ipc.generic
Requestor implementation for generic Java data.
GenericRequestor(Protocol, Transceiver) - Constructor for class org.apache.avro.ipc.generic.GenericRequestor
 
GenericRequestor(Protocol, Transceiver, GenericData) - Constructor for class org.apache.avro.ipc.generic.GenericRequestor
 
GenericResponder - Class in org.apache.avro.ipc.generic
Responder implementation for generic Java data.
GenericResponder(Protocol) - Constructor for class org.apache.avro.ipc.generic.GenericResponder
 
GenericResponder(Protocol, GenericData) - Constructor for class org.apache.avro.ipc.generic.GenericResponder
 
get() - Method in class org.apache.avro.ipc.CallFuture
 
get(long, TimeUnit) - Method in class org.apache.avro.ipc.CallFuture
 
get(int) - Method in class org.apache.avro.ipc.HandshakeRequest
 
get(int) - Method in class org.apache.avro.ipc.HandshakeResponse
 
getCharts() - Method in class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
 
getClassSchema() - Static method in enum org.apache.avro.ipc.HandshakeMatch
 
getClassSchema() - Static method in class org.apache.avro.ipc.HandshakeRequest
 
getClassSchema() - Static method in class org.apache.avro.ipc.HandshakeResponse
 
getClassSchema() - Static method in class org.apache.avro.ipc.MD5
 
getClient(Class<T>, Transceiver) - Static method in class org.apache.avro.ipc.reflect.ReflectRequestor
Create a proxy instance whose methods invoke RPCs.
getClient(Class<T>, Transceiver, ReflectData) - Static method in class org.apache.avro.ipc.reflect.ReflectRequestor
Create a proxy instance whose methods invoke RPCs.
getClient(Class<T>, ReflectRequestor) - Static method in class org.apache.avro.ipc.reflect.ReflectRequestor
Create a proxy instance whose methods invoke RPCs.
getClient(Class<T>, Transceiver) - Static method in class org.apache.avro.ipc.specific.SpecificRequestor
Create a proxy instance whose methods invoke RPCs.
getClient(Class<T>, Transceiver, SpecificData) - Static method in class org.apache.avro.ipc.specific.SpecificRequestor
Create a proxy instance whose methods invoke RPCs.
getClient(Class<T>, SpecificRequestor) - Static method in class org.apache.avro.ipc.specific.SpecificRequestor
Create a proxy instance whose methods invoke RPCs.
getClientHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Gets the value of the 'clientHash' field.
getClientHash() - Method in class org.apache.avro.ipc.HandshakeRequest
Gets the value of the 'clientHash' field.
getClientProtocol() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Gets the value of the 'clientProtocol' field.
getClientProtocol() - Method in class org.apache.avro.ipc.HandshakeRequest
Gets the value of the 'clientProtocol' field.
getDatas() - Method in class org.apache.avro.ipc.NettyTransportCodec.NettyDataPack
 
getDatumReader(Schema, Schema) - Method in class org.apache.avro.ipc.generic.GenericResponder
 
getDatumReader(Schema, Schema) - Method in class org.apache.avro.ipc.reflect.ReflectRequestor
 
getDatumReader(Schema, Schema) - Method in class org.apache.avro.ipc.reflect.ReflectResponder
 
getDatumReader(Schema) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
Deprecated.
getDatumReader(Schema, Schema) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
 
getDatumReader(Schema, Schema) - Method in class org.apache.avro.ipc.specific.SpecificResponder
 
getDatumWriter(Schema) - Method in class org.apache.avro.ipc.generic.GenericResponder
 
getDatumWriter(Schema) - Method in class org.apache.avro.ipc.reflect.ReflectRequestor
 
getDatumWriter(Schema) - Method in class org.apache.avro.ipc.reflect.ReflectResponder
 
getDatumWriter(Schema) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
 
getDatumWriter(Schema) - Method in class org.apache.avro.ipc.specific.SpecificResponder
 
getDecoder() - Static method in class org.apache.avro.ipc.HandshakeRequest
Return the BinaryMessageDecoder instance used by this class.
getDecoder() - Static method in class org.apache.avro.ipc.HandshakeResponse
Return the BinaryMessageDecoder instance used by this class.
getError() - Method in class org.apache.avro.ipc.CallFuture
Gets the error that was thrown during RPC execution.
getGenericData() - Method in class org.apache.avro.ipc.generic.GenericRequestor
 
getGenericData() - Method in class org.apache.avro.ipc.generic.GenericResponder
 
getHandshakeRequest() - Method in class org.apache.avro.ipc.RPCContext
Get the handshake request of this RPC.
getHandshakeResponse() - Method in class org.apache.avro.ipc.RPCContext
Get the handshake response of this RPC.
getLocal() - Method in class org.apache.avro.ipc.Requestor
 
getLocal() - Method in class org.apache.avro.ipc.Responder
Return the local protocol.
getMatch() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Gets the value of the 'match' field.
getMatch() - Method in class org.apache.avro.ipc.HandshakeResponse
Gets the value of the 'match' field.
getMessage() - Method in class org.apache.avro.ipc.RPCContext
Returns the Protocol.Message corresponding to this RPC
getMeta() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Gets the value of the 'meta' field.
getMeta() - Method in class org.apache.avro.ipc.HandshakeRequest
Gets the value of the 'meta' field.
getMeta() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Gets the value of the 'meta' field.
getMeta() - Method in class org.apache.avro.ipc.HandshakeResponse
Gets the value of the 'meta' field.
getname() - Method in class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
 
getNumActiveConnections() - Method in class org.apache.avro.ipc.NettyServer
 
getNumCalls() - Method in class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
 
getPort() - Method in class org.apache.avro.ipc.DatagramServer
 
getPort() - Method in class org.apache.avro.ipc.HttpServer
 
getPort() - Method in class org.apache.avro.ipc.NettyServer
 
getPort() - Method in interface org.apache.avro.ipc.Server
The port this server runs on.
getPort() - Method in class org.apache.avro.ipc.SocketServer
Deprecated.
 
getReflectData() - Method in class org.apache.avro.ipc.reflect.ReflectRequestor
 
getReflectData() - Method in class org.apache.avro.ipc.reflect.ReflectResponder
 
getRemote() - Method in class org.apache.avro.ipc.NettyTransceiver
 
getRemote() - Method in class org.apache.avro.ipc.Requestor
Return the remote protocol.
getRemote() - Static method in class org.apache.avro.ipc.Responder
Return the remote protocol.
getRemote() - Method in class org.apache.avro.ipc.SaslSocketTransceiver
 
getRemote() - Method in class org.apache.avro.ipc.SocketTransceiver
Deprecated.
 
getRemote(Object) - Static method in class org.apache.avro.ipc.specific.SpecificRequestor
Return the remote protocol for a proxy.
getRemote() - Method in class org.apache.avro.ipc.Transceiver
Returns the protocol passed to Transceiver.setRemote(Protocol).
getRemoteName() - Method in class org.apache.avro.ipc.DatagramTransceiver
 
getRemoteName() - Method in class org.apache.avro.ipc.HttpTransceiver
 
getRemoteName() - Method in class org.apache.avro.ipc.LocalTransceiver
 
getRemoteName() - Method in class org.apache.avro.ipc.NettyTransceiver
 
getRemoteName() - Method in class org.apache.avro.ipc.SaslSocketTransceiver
 
getRemoteName() - Method in class org.apache.avro.ipc.SocketTransceiver
Deprecated.
 
getRemoteName() - Method in class org.apache.avro.ipc.Transceiver
 
getRequestPayload() - Method in class org.apache.avro.ipc.RPCContext
Returns the serialized payload of the request in this RPC.
getResource(String) - Method in class org.apache.avro.ipc.stats.StaticServlet
 
getResponsePayload() - Method in class org.apache.avro.ipc.RPCContext
Returns the serialized payload of the response in this RPC.
getResult() - Method in class org.apache.avro.ipc.CallFuture
Gets the value of the RPC result without blocking.
getSchema() - Method in class org.apache.avro.ipc.HandshakeRequest
 
getSchema() - Method in class org.apache.avro.ipc.HandshakeResponse
 
getSchema() - Method in class org.apache.avro.ipc.MD5
 
getSerial() - Method in class org.apache.avro.ipc.NettyTransportCodec.NettyDataPack
 
getServerHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Gets the value of the 'serverHash' field.
getServerHash() - Method in class org.apache.avro.ipc.HandshakeRequest
Gets the value of the 'serverHash' field.
getServerHash() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Gets the value of the 'serverHash' field.
getServerHash() - Method in class org.apache.avro.ipc.HandshakeResponse
Gets the value of the 'serverHash' field.
getServerProtocol() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Gets the value of the 'serverProtocol' field.
getServerProtocol() - Method in class org.apache.avro.ipc.HandshakeResponse
Gets the value of the 'serverProtocol' field.
getSpecificData() - Method in class org.apache.avro.ipc.specific.SpecificRequestor
 
getSpecificData() - Method in class org.apache.avro.ipc.specific.SpecificResponder
 
getTransceiver() - Method in class org.apache.avro.ipc.Requestor
 
getTransceiver(SocketChannel) - Method in class org.apache.avro.ipc.SaslSocketServer
 
getTransceiver(SocketChannel) - Method in class org.apache.avro.ipc.SocketServer
Deprecated.
Creates an appropriate Transceiver for this server.

H

handleError(Throwable) - Method in interface org.apache.avro.ipc.Callback
Receives an error.
handleError(Throwable) - Method in class org.apache.avro.ipc.CallFuture
Sets an error thrown during RPC execution, and unblocks all threads waiting on CallFuture.get() or CallFuture.get(long, TimeUnit).
handleError(Throwable) - Method in class org.apache.avro.ipc.Requestor.TransceiverCallback
 
handleResult(T) - Method in interface org.apache.avro.ipc.Callback
Receives a callback result.
handleResult(T) - Method in class org.apache.avro.ipc.CallFuture
Sets the RPC response, and unblocks all threads waiting on CallFuture.get() or CallFuture.get(long, TimeUnit).
handleResult(List<ByteBuffer>) - Method in class org.apache.avro.ipc.Requestor.TransceiverCallback
 
handleUpstream(ChannelHandlerContext, ChannelEvent) - Method in class org.apache.avro.ipc.NettyTransceiver.NettyClientAvroHandler
 
HandshakeMatch - Enum in org.apache.avro.ipc
 
HandshakeRequest - Class in org.apache.avro.ipc
 
HandshakeRequest() - Constructor for class org.apache.avro.ipc.HandshakeRequest
Default constructor.
HandshakeRequest(MD5, String, MD5, Map<String, ByteBuffer>) - Constructor for class org.apache.avro.ipc.HandshakeRequest
All-args constructor.
HandshakeRequest.Builder - Class in org.apache.avro.ipc
RecordBuilder for HandshakeRequest instances.
HandshakeResponse - Class in org.apache.avro.ipc
 
HandshakeResponse() - Constructor for class org.apache.avro.ipc.HandshakeResponse
Default constructor.
HandshakeResponse(HandshakeMatch, String, MD5, Map<String, ByteBuffer>) - Constructor for class org.apache.avro.ipc.HandshakeResponse
All-args constructor.
HandshakeResponse.Builder - Class in org.apache.avro.ipc
RecordBuilder for HandshakeResponse instances.
hasClientHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Checks whether the 'clientHash' field has been set.
hasClientProtocol() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Checks whether the 'clientProtocol' field has been set.
hasMatch() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Checks whether the 'match' field has been set.
hasMeta() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Checks whether the 'meta' field has been set.
hasMeta() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Checks whether the 'meta' field has been set.
hasServerHash() - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Checks whether the 'serverHash' field has been set.
hasServerHash() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Checks whether the 'serverHash' field has been set.
hasServerProtocol() - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Checks whether the 'serverProtocol' field has been set.
HttpServer - Class in org.apache.avro.ipc
An HTTP-based RPC Server.
HttpServer(Responder, int) - Constructor for class org.apache.avro.ipc.HttpServer
Constructs a server to run on the named port.
HttpServer(ResponderServlet, int) - Constructor for class org.apache.avro.ipc.HttpServer
Constructs a server to run on the named port.
HttpServer(Responder, String, int) - Constructor for class org.apache.avro.ipc.HttpServer
Constructs a server to run on the named port on the specified address.
HttpServer(ResponderServlet, String, int) - Constructor for class org.apache.avro.ipc.HttpServer
Constructs a server to run on the named port on the specified address.
HttpServer(Responder, ConnectionFactory, String, int) - Constructor for class org.apache.avro.ipc.HttpServer
Constructs a server to run with the given ConnectionFactory on the given address/port.
HttpServer(ResponderServlet, ConnectionFactory, String, int) - Constructor for class org.apache.avro.ipc.HttpServer
Constructs a server to run with the given ConnectionFactory on the given address/port.
HttpServer(ResponderServlet, Connector) - Constructor for class org.apache.avro.ipc.HttpServer
Deprecated.
- use the Constructors that take a ConnectionFactory
HttpServer(Responder, Connector) - Constructor for class org.apache.avro.ipc.HttpServer
Deprecated.
- use the Constructors that take a ConnectionFactory
HttpTransceiver - Class in org.apache.avro.ipc
An HTTP-based Transceiver implementation.
HttpTransceiver(URL) - Constructor for class org.apache.avro.ipc.HttpTransceiver
 
HttpTransceiver(URL, Proxy) - Constructor for class org.apache.avro.ipc.HttpTransceiver
 

I

invoke(Object, Method, Object[]) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
 
Ipc - Class in org.apache.avro.ipc
IPC utilities, including client and server factories.
isCancelled() - Method in class org.apache.avro.ipc.CallFuture
 
isConnected() - Method in class org.apache.avro.ipc.NettyTransceiver
 
isConnected() - Method in class org.apache.avro.ipc.SaslSocketTransceiver
 
isConnected() - Method in class org.apache.avro.ipc.SocketTransceiver
Deprecated.
 
isConnected() - Method in class org.apache.avro.ipc.Transceiver
True if a handshake has been completed for this connection.
isDone() - Method in class org.apache.avro.ipc.CallFuture
 
isError() - Method in class org.apache.avro.ipc.RPCContext
Indicates whether an exception was generated at the server

J

join() - Method in class org.apache.avro.ipc.HttpServer
 
join() - Method in class org.apache.avro.ipc.NettyServer
 
join() - Method in interface org.apache.avro.ipc.Server
Wait for this server to exit.

L

LocalTransceiver - Class in org.apache.avro.ipc
Implementation of IPC that remains in process.
LocalTransceiver(Responder) - Constructor for class org.apache.avro.ipc.LocalTransceiver
 
lockChannel() - Method in class org.apache.avro.ipc.NettyTransceiver
Netty channels are thread-safe, so there is no need to acquire locks.
lockChannel() - Method in class org.apache.avro.ipc.Transceiver
Acquires an exclusive lock on the transceiver's channel.

M

main(String[]) - Static method in class org.apache.avro.ipc.DatagramServer
 
main(String[]) - Static method in class org.apache.avro.ipc.SocketServer
Deprecated.
 
match - Variable in class org.apache.avro.ipc.HandshakeResponse
Deprecated.
MD5 - Class in org.apache.avro.ipc
 
MD5() - Constructor for class org.apache.avro.ipc.MD5
Creates a new MD5
MD5(byte[]) - Constructor for class org.apache.avro.ipc.MD5
Creates a new MD5 with the given bytes.
messageReceived(ChannelHandlerContext, MessageEvent) - Method in class org.apache.avro.ipc.NettyTransceiver.NettyClientAvroHandler
 
meta - Variable in class org.apache.avro.ipc.HandshakeRequest
Deprecated.
meta - Variable in class org.apache.avro.ipc.HandshakeResponse
Deprecated.

N

name - Variable in class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
 
NETTY_CONNECT_TIMEOUT_OPTION - Static variable in class org.apache.avro.ipc.NettyTransceiver
 
NETTY_KEEPALIVE_OPTION - Static variable in class org.apache.avro.ipc.NettyTransceiver
 
NETTY_TCP_NODELAY_OPTION - Static variable in class org.apache.avro.ipc.NettyTransceiver
 
NettyClientAvroHandler() - Constructor for class org.apache.avro.ipc.NettyTransceiver.NettyClientAvroHandler
 
NettyDataPack() - Constructor for class org.apache.avro.ipc.NettyTransportCodec.NettyDataPack
 
NettyDataPack(int, List<ByteBuffer>) - Constructor for class org.apache.avro.ipc.NettyTransportCodec.NettyDataPack
 
NettyFrameDecoder() - Constructor for class org.apache.avro.ipc.NettyTransportCodec.NettyFrameDecoder
 
NettyFrameEncoder() - Constructor for class org.apache.avro.ipc.NettyTransportCodec.NettyFrameEncoder
 
NettyServer - Class in org.apache.avro.ipc
A Netty-based RPC Server implementation.
NettyServer(Responder, InetSocketAddress) - Constructor for class org.apache.avro.ipc.NettyServer
 
NettyServer(Responder, InetSocketAddress, ChannelFactory) - Constructor for class org.apache.avro.ipc.NettyServer
 
NettyServer(Responder, InetSocketAddress, ChannelFactory, ChannelPipelineFactory, ExecutionHandler) - Constructor for class org.apache.avro.ipc.NettyServer
 
NettyServer(Responder, InetSocketAddress, ChannelFactory, ExecutionHandler) - Constructor for class org.apache.avro.ipc.NettyServer
 
NettyTransceiver - Class in org.apache.avro.ipc
A Netty-based Transceiver implementation.
NettyTransceiver(InetSocketAddress) - Constructor for class org.apache.avro.ipc.NettyTransceiver
Creates a NettyTransceiver, and attempts to connect to the given address.
NettyTransceiver(InetSocketAddress, Long) - Constructor for class org.apache.avro.ipc.NettyTransceiver
Creates a NettyTransceiver, and attempts to connect to the given address.
NettyTransceiver(InetSocketAddress, ChannelFactory) - Constructor for class org.apache.avro.ipc.NettyTransceiver
Creates a NettyTransceiver, and attempts to connect to the given address.
NettyTransceiver(InetSocketAddress, ChannelFactory, Long) - Constructor for class org.apache.avro.ipc.NettyTransceiver
Creates a NettyTransceiver, and attempts to connect to the given address.
NettyTransceiver(InetSocketAddress, ChannelFactory, Map<String, Object>) - Constructor for class org.apache.avro.ipc.NettyTransceiver
Creates a NettyTransceiver, and attempts to connect to the given address.
NettyTransceiver.NettyClientAvroHandler - Class in org.apache.avro.ipc
Avro client handler for the Netty transport
NettyTransceiver.NettyTransceiverThreadFactory - Class in org.apache.avro.ipc
Creates threads with unique names based on a specified name prefix.
NettyTransceiver.WriteFutureListener - Class in org.apache.avro.ipc
A ChannelFutureListener for channel write operations that notifies a Callback if an error occurs while writing to the channel.
NettyTransceiverThreadFactory(String) - Constructor for class org.apache.avro.ipc.NettyTransceiver.NettyTransceiverThreadFactory
Creates a NettyTransceiverThreadFactory that creates threads with the specified name.
NettyTransportCodec - Class in org.apache.avro.ipc
Data structure, encoder and decoder classes for the Netty transport.
NettyTransportCodec() - Constructor for class org.apache.avro.ipc.NettyTransportCodec
 
NettyTransportCodec.NettyDataPack - Class in org.apache.avro.ipc
Transport protocol data structure when using Netty.
NettyTransportCodec.NettyFrameDecoder - Class in org.apache.avro.ipc
Protocol decoder which converts Netty's ChannelBuffer to NettyDataPack which contains a List<ByteBuffer> needed by Avro Responder.
NettyTransportCodec.NettyFrameEncoder - Class in org.apache.avro.ipc
Protocol encoder which converts NettyDataPack which contains the Responder's output List<ByteBuffer> to ChannelBuffer needed by Netty.
newBuilder() - Static method in class org.apache.avro.ipc.HandshakeRequest
Creates a new HandshakeRequest RecordBuilder.
newBuilder(HandshakeRequest.Builder) - Static method in class org.apache.avro.ipc.HandshakeRequest
Creates a new HandshakeRequest RecordBuilder by copying an existing Builder.
newBuilder(HandshakeRequest) - Static method in class org.apache.avro.ipc.HandshakeRequest
Creates a new HandshakeRequest RecordBuilder by copying an existing HandshakeRequest instance.
newBuilder() - Static method in class org.apache.avro.ipc.HandshakeResponse
Creates a new HandshakeResponse RecordBuilder.
newBuilder(HandshakeResponse.Builder) - Static method in class org.apache.avro.ipc.HandshakeResponse
Creates a new HandshakeResponse RecordBuilder by copying an existing Builder.
newBuilder(HandshakeResponse) - Static method in class org.apache.avro.ipc.HandshakeResponse
Creates a new HandshakeResponse RecordBuilder by copying an existing HandshakeResponse instance.
newThread(Runnable) - Method in class org.apache.avro.ipc.NettyTransceiver.NettyTransceiverThreadFactory
 
numCalls - Variable in class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
 

O

operationComplete(ChannelFuture) - Method in class org.apache.avro.ipc.NettyTransceiver.WriteFutureListener
 
org.apache.avro.ipc - package org.apache.avro.ipc
 
org.apache.avro.ipc.generic - package org.apache.avro.ipc.generic
 
org.apache.avro.ipc.reflect - package org.apache.avro.ipc.reflect
 
org.apache.avro.ipc.specific - package org.apache.avro.ipc.specific
 
org.apache.avro.ipc.stats - package org.apache.avro.ipc.stats
Utilities to collect and display IPC statistics.

P

put(int, Object) - Method in class org.apache.avro.ipc.HandshakeRequest
 
put(int, Object) - Method in class org.apache.avro.ipc.HandshakeResponse
 

R

readBuffers() - Method in class org.apache.avro.ipc.DatagramTransceiver
 
readBuffers() - Method in class org.apache.avro.ipc.HttpTransceiver
 
readBuffers() - Method in class org.apache.avro.ipc.LocalTransceiver
 
readBuffers() - Method in class org.apache.avro.ipc.NettyTransceiver
 
readBuffers() - Method in class org.apache.avro.ipc.SaslSocketTransceiver
 
readBuffers() - Method in class org.apache.avro.ipc.SocketTransceiver
Deprecated.
 
readBuffers() - Method in class org.apache.avro.ipc.Transceiver
Called by the default definition of Transceiver.transceive(List).
readError(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.generic.GenericRequestor
 
readError(Schema, Decoder) - Method in class org.apache.avro.ipc.Requestor
Deprecated.
readError(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.Requestor
Reads an error message.
readError(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
 
readExternal(ObjectInput) - Method in class org.apache.avro.ipc.HandshakeRequest
 
readExternal(ObjectInput) - Method in class org.apache.avro.ipc.HandshakeResponse
 
readExternal(ObjectInput) - Method in class org.apache.avro.ipc.MD5
 
readRequest(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.generic.GenericResponder
 
readRequest(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.Responder
Reads a request message.
readResponse(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.generic.GenericRequestor
 
readResponse(Schema, Decoder) - Method in class org.apache.avro.ipc.Requestor
Deprecated.
readResponse(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.Requestor
Reads a response message.
readResponse(Schema, Schema, Decoder) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
 
ReflectRequestor - Class in org.apache.avro.ipc.reflect
A Requestor for existing interfaces.
ReflectRequestor(Class<?>, Transceiver) - Constructor for class org.apache.avro.ipc.reflect.ReflectRequestor
 
ReflectRequestor(Protocol, Transceiver) - Constructor for class org.apache.avro.ipc.reflect.ReflectRequestor
 
ReflectRequestor(Class<?>, Transceiver, ReflectData) - Constructor for class org.apache.avro.ipc.reflect.ReflectRequestor
 
ReflectRequestor(Protocol, Transceiver, ReflectData) - Constructor for class org.apache.avro.ipc.reflect.ReflectRequestor
 
ReflectResponder - Class in org.apache.avro.ipc.reflect
Responder for existing interfaces.
ReflectResponder(Class, Object) - Constructor for class org.apache.avro.ipc.reflect.ReflectResponder
 
ReflectResponder(Protocol, Object) - Constructor for class org.apache.avro.ipc.reflect.ReflectResponder
 
ReflectResponder(Class, Object, ReflectData) - Constructor for class org.apache.avro.ipc.reflect.ReflectResponder
 
ReflectResponder(Protocol, Object, ReflectData) - Constructor for class org.apache.avro.ipc.reflect.ReflectResponder
 
RenderableMessage(String) - Constructor for class org.apache.avro.ipc.stats.StatsServlet.RenderableMessage
 
request(String, Object) - Method in class org.apache.avro.ipc.generic.GenericRequestor
 
request(String, Object, Callback<T>) - Method in class org.apache.avro.ipc.generic.GenericRequestor
 
request(String, Object) - Method in class org.apache.avro.ipc.Requestor
Writes a request message and reads a response or error message.
request(String, Object, Callback<T>) - Method in class org.apache.avro.ipc.Requestor
Writes a request message and returns the result through a Callback.
requestCallMeta - Variable in class org.apache.avro.ipc.RPCContext
 
requestCallMeta() - Method in class org.apache.avro.ipc.RPCContext
This is an access method for the per-call state provided by the client to the server.
requestHandshakeMeta() - Method in class org.apache.avro.ipc.RPCContext
This is an access method for the handshake state provided by the client to the server.
Requestor - Class in org.apache.avro.ipc
Base class for the client side of a protocol interaction.
Requestor(Protocol, Transceiver) - Constructor for class org.apache.avro.ipc.Requestor
 
Requestor.TransceiverCallback<T> - Class in org.apache.avro.ipc
Handles callbacks from transceiver invocations.
respond(List<ByteBuffer>) - Method in class org.apache.avro.ipc.Responder
Called by a server to deserialize a request, compute and serialize a response or error.
respond(List<ByteBuffer>, Transceiver) - Method in class org.apache.avro.ipc.Responder
Called by a server to deserialize a request, compute and serialize a response or error.
respond(Protocol.Message, Object) - Method in class org.apache.avro.ipc.Responder
Computes the response for a message.
respond(Protocol.Message, Object) - Method in class org.apache.avro.ipc.specific.SpecificResponder
 
Responder - Class in org.apache.avro.ipc
Base class for the server side of a protocol interaction.
Responder(Protocol) - Constructor for class org.apache.avro.ipc.Responder
 
ResponderServlet - Class in org.apache.avro.ipc
An HttpServlet that responds to Avro RPC requests.
ResponderServlet(Responder) - Constructor for class org.apache.avro.ipc.ResponderServlet
 
response - Variable in class org.apache.avro.ipc.RPCContext
 
response() - Method in class org.apache.avro.ipc.RPCContext
The response object generated at the server, if it exists.
responseCallMeta - Variable in class org.apache.avro.ipc.RPCContext
 
responseCallMeta() - Method in class org.apache.avro.ipc.RPCContext
This is an access method for the per-call state provided by the server back to the client.
responseHandshakeMeta() - Method in class org.apache.avro.ipc.RPCContext
This is an access method for the handshake state provided by the server back to the client
RPCContext - Class in org.apache.avro.ipc
This class represents the context of an RPC call or RPC handshake.
RPCContext() - Constructor for class org.apache.avro.ipc.RPCContext
 
rpcMetaPlugins - Variable in class org.apache.avro.ipc.Requestor
 
rpcMetaPlugins - Variable in class org.apache.avro.ipc.Responder
 
RPCPlugin - Class in org.apache.avro.ipc
An instrumentation API for RPC metadata.
RPCPlugin() - Constructor for class org.apache.avro.ipc.RPCPlugin
 
run() - Method in class org.apache.avro.ipc.DatagramServer
 
run() - Method in class org.apache.avro.ipc.SocketServer
Deprecated.
 

S

SaslSocketServer - Class in org.apache.avro.ipc
A Server that uses javax.security.sasl for authentication and encryption.
SaslSocketServer(Responder, SocketAddress) - Constructor for class org.apache.avro.ipc.SaslSocketServer
Create using SASL's anonymous (RFC 2245) mechanism.
SaslSocketServer(Responder, SocketAddress, String, String, String, Map<String, ?>, CallbackHandler) - Constructor for class org.apache.avro.ipc.SaslSocketServer
Create using the specified SaslServer parameters.
SaslSocketTransceiver - Class in org.apache.avro.ipc
A Transceiver that uses javax.security.sasl for authentication and encryption.
SaslSocketTransceiver(SocketAddress) - Constructor for class org.apache.avro.ipc.SaslSocketTransceiver
Create using SASL's anonymous (RFC 2245) mechanism.
SaslSocketTransceiver(SocketAddress, SaslClient) - Constructor for class org.apache.avro.ipc.SaslSocketTransceiver
Create using the specified SaslClient.
SaslSocketTransceiver(SocketChannel, SaslServer) - Constructor for class org.apache.avro.ipc.SaslSocketTransceiver
Create using the specified SaslServer.
SCHEMA$ - Static variable in enum org.apache.avro.ipc.HandshakeMatch
 
SCHEMA$ - Static variable in class org.apache.avro.ipc.HandshakeRequest
 
SCHEMA$ - Static variable in class org.apache.avro.ipc.HandshakeResponse
 
SCHEMA$ - Static variable in class org.apache.avro.ipc.MD5
 
Server - Interface in org.apache.avro.ipc
A server listening on a port.
serverConnecting(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
Called on the server during the RPC handshake
serverHash - Variable in class org.apache.avro.ipc.HandshakeRequest
Deprecated.
serverHash - Variable in class org.apache.avro.ipc.HandshakeResponse
Deprecated.
serverProtocol - Variable in class org.apache.avro.ipc.HandshakeResponse
Deprecated.
serverReceiveRequest(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
This method is invoked at the RPC server when the request is received, but before the call itself is executed
serverReceiveRequest(RPCContext) - Method in class org.apache.avro.ipc.stats.StatsPlugin
 
serverSendResponse(RPCContext) - Method in class org.apache.avro.ipc.RPCPlugin
This method is invoked at the server before the response is executed, but before the response has been formulated
serverSendResponse(RPCContext) - Method in class org.apache.avro.ipc.stats.StatsPlugin
 
setClientHash(MD5) - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Sets the value of the 'clientHash' field.
setClientHash(MD5) - Method in class org.apache.avro.ipc.HandshakeRequest
Sets the value of the 'clientHash' field.
setClientProtocol(String) - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Sets the value of the 'clientProtocol' field.
setClientProtocol(String) - Method in class org.apache.avro.ipc.HandshakeRequest
Sets the value of the 'clientProtocol' field.
setDatas(List<ByteBuffer>) - Method in class org.apache.avro.ipc.NettyTransportCodec.NettyDataPack
 
setHandshakeRequest(HandshakeRequest) - Method in class org.apache.avro.ipc.RPCContext
Set the handshake request of this RPC.
setHandshakeResponse(HandshakeResponse) - Method in class org.apache.avro.ipc.RPCContext
Set the handshake response of this RPC.
setMatch(HandshakeMatch) - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Sets the value of the 'match' field.
setMatch(HandshakeMatch) - Method in class org.apache.avro.ipc.HandshakeResponse
Sets the value of the 'match' field.
setMessage(Protocol.Message) - Method in class org.apache.avro.ipc.RPCContext
Sets the Protocol.Message corresponding to this RPC
setMeta(Map<String, ByteBuffer>) - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Sets the value of the 'meta' field.
setMeta(Map<String, ByteBuffer>) - Method in class org.apache.avro.ipc.HandshakeRequest
Sets the value of the 'meta' field.
setMeta(Map<String, ByteBuffer>) - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Sets the value of the 'meta' field.
setMeta(Map<String, ByteBuffer>) - Method in class org.apache.avro.ipc.HandshakeResponse
Sets the value of the 'meta' field.
setRemote(Protocol) - Method in class org.apache.avro.ipc.NettyTransceiver
 
setRemote(Protocol) - Method in class org.apache.avro.ipc.SaslSocketTransceiver
 
setRemote(Protocol) - Method in class org.apache.avro.ipc.SocketTransceiver
Deprecated.
 
setRemote(Protocol) - Method in class org.apache.avro.ipc.Transceiver
Called with the remote protocol when a handshake has been completed.
setRequestPayload(List<ByteBuffer>) - Method in class org.apache.avro.ipc.RPCContext
Sets the serialized payload of the request in this RPC.
setResponsePayload(List<ByteBuffer>) - Method in class org.apache.avro.ipc.RPCContext
Sets the serialized payload of the response in this RPC.
setSerial(int) - Method in class org.apache.avro.ipc.NettyTransportCodec.NettyDataPack
 
setServerHash(MD5) - Method in class org.apache.avro.ipc.HandshakeRequest.Builder
Sets the value of the 'serverHash' field.
setServerHash(MD5) - Method in class org.apache.avro.ipc.HandshakeRequest
Sets the value of the 'serverHash' field.
setServerHash(MD5) - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Sets the value of the 'serverHash' field.
setServerHash(MD5) - Method in class org.apache.avro.ipc.HandshakeResponse
Sets the value of the 'serverHash' field.
setServerProtocol(String) - Method in class org.apache.avro.ipc.HandshakeResponse.Builder
Sets the value of the 'serverProtocol' field.
setServerProtocol(String) - Method in class org.apache.avro.ipc.HandshakeResponse
Sets the value of the 'serverProtocol' field.
setTimeout(int) - Method in class org.apache.avro.ipc.HttpTransceiver
Set the connect and read timeouts, in milliseconds.
SocketServer - Class in org.apache.avro.ipc
Deprecated.
use SaslSocketServer instead.
SocketServer(Responder, SocketAddress) - Constructor for class org.apache.avro.ipc.SocketServer
Deprecated.
 
SocketTransceiver - Class in org.apache.avro.ipc
Deprecated.
SocketTransceiver(SocketAddress) - Constructor for class org.apache.avro.ipc.SocketTransceiver
Deprecated.
 
SocketTransceiver(SocketChannel) - Constructor for class org.apache.avro.ipc.SocketTransceiver
Deprecated.
 
SpecificRequestor - Class in org.apache.avro.ipc.specific
Requestor for generated interfaces.
SpecificRequestor(Class<?>, Transceiver) - Constructor for class org.apache.avro.ipc.specific.SpecificRequestor
 
SpecificRequestor(Protocol, Transceiver) - Constructor for class org.apache.avro.ipc.specific.SpecificRequestor
 
SpecificRequestor(Class<?>, Transceiver, SpecificData) - Constructor for class org.apache.avro.ipc.specific.SpecificRequestor
 
SpecificRequestor(Protocol, Transceiver, SpecificData) - Constructor for class org.apache.avro.ipc.specific.SpecificRequestor
 
SpecificResponder - Class in org.apache.avro.ipc.specific
Responder for generated interfaces.
SpecificResponder(Class, Object) - Constructor for class org.apache.avro.ipc.specific.SpecificResponder
 
SpecificResponder(Protocol, Object) - Constructor for class org.apache.avro.ipc.specific.SpecificResponder
 
SpecificResponder(Class, Object, SpecificData) - Constructor for class org.apache.avro.ipc.specific.SpecificResponder
 
SpecificResponder(Protocol, Object, SpecificData) - Constructor for class org.apache.avro.ipc.specific.SpecificResponder
 
start() - Method in class org.apache.avro.ipc.HttpServer
Start the server.
start() - Method in class org.apache.avro.ipc.NettyServer
 
start() - Method in interface org.apache.avro.ipc.Server
Start this server.
startupTime - Variable in class org.apache.avro.ipc.stats.StatsPlugin
How long I've been alive
StaticServlet - Class in org.apache.avro.ipc.stats
Very simple servlet class capable of serving static files.
StaticServlet() - Constructor for class org.apache.avro.ipc.stats.StaticServlet
 
StatsPlugin - Class in org.apache.avro.ipc.stats
Collects count and latency statistics about RPC calls.
StatsPlugin() - Constructor for class org.apache.avro.ipc.stats.StatsPlugin
Construct a plugin with default (system) ticks, and default histogram segmentation.
StatsServer - Class in org.apache.avro.ipc.stats
 
StatsServer(StatsPlugin, int) - Constructor for class org.apache.avro.ipc.stats.StatsServer
 
StatsServlet - Class in org.apache.avro.ipc.stats
Exposes information provided by a StatsPlugin as a web page.
StatsServlet(StatsPlugin) - Constructor for class org.apache.avro.ipc.stats.StatsServlet
 
StatsServlet.RenderableMessage - Class in org.apache.avro.ipc.stats
 
stop() - Method in class org.apache.avro.ipc.stats.StatsServer
 

T

toByteBuffer() - Method in class org.apache.avro.ipc.HandshakeRequest
Serializes this HandshakeRequest to a ByteBuffer.
toByteBuffer() - Method in class org.apache.avro.ipc.HandshakeResponse
Serializes this HandshakeResponse to a ByteBuffer.
transceive(List<ByteBuffer>) - Method in class org.apache.avro.ipc.LocalTransceiver
 
transceive(List<ByteBuffer>) - Method in class org.apache.avro.ipc.NettyTransceiver
Override as non-synchronized method because the method is thread safe.
transceive(List<ByteBuffer>, Callback<List<ByteBuffer>>) - Method in class org.apache.avro.ipc.NettyTransceiver
 
transceive(List<ByteBuffer>) - Method in class org.apache.avro.ipc.SaslSocketTransceiver
 
transceive(List<ByteBuffer>) - Method in class org.apache.avro.ipc.Transceiver
Called by Requestor.request(String,Object) for two-way messages.
transceive(List<ByteBuffer>, Callback<List<ByteBuffer>>) - Method in class org.apache.avro.ipc.Transceiver
Called by Requestor.request(String,Object,Callback) for two-way messages using callbacks.
Transceiver - Class in org.apache.avro.ipc
Base transport class used by Requestor.
Transceiver() - Constructor for class org.apache.avro.ipc.Transceiver
 
TransceiverCallback(Requestor.Request, Callback<T>) - Constructor for class org.apache.avro.ipc.Requestor.TransceiverCallback
Creates a TransceiverCallback.

U

unlockChannel() - Method in class org.apache.avro.ipc.NettyTransceiver
Netty channels are thread-safe, so there is no need to acquire locks.
unlockChannel() - Method in class org.apache.avro.ipc.Transceiver
Releases the lock on the transceiver's channel if held by the calling thread.

V

valueOf(String) - Static method in enum org.apache.avro.ipc.HandshakeMatch
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.avro.ipc.HandshakeMatch
Returns an array containing the constants of this enum type, in the order they are declared.

W

writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.DatagramTransceiver
 
writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.HttpTransceiver
 
writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.LocalTransceiver
 
writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.NettyTransceiver
 
writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.SaslSocketTransceiver
 
writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.SocketTransceiver
Deprecated.
 
writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.Transceiver
Called by Requestor.request(String,Object) for one-way messages.
writeError(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.generic.GenericResponder
 
writeError(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.reflect.ReflectResponder
 
writeError(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.Responder
Writes an error message.
writeError(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.specific.SpecificResponder
 
writeExternal(ObjectOutput) - Method in class org.apache.avro.ipc.HandshakeRequest
 
writeExternal(ObjectOutput) - Method in class org.apache.avro.ipc.HandshakeResponse
 
writeExternal(ObjectOutput) - Method in class org.apache.avro.ipc.MD5
 
WriteFutureListener(Callback<List<ByteBuffer>>) - Constructor for class org.apache.avro.ipc.NettyTransceiver.WriteFutureListener
Creates a WriteFutureListener that notifies the given callback if an error occurs writing data to the channel.
writeRequest(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.generic.GenericRequestor
 
writeRequest(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.Requestor
Writes a request message.
writeRequest(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.specific.SpecificRequestor
 
writeResponse(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.generic.GenericResponder
 
writeResponse(Schema, Object, Encoder) - Method in class org.apache.avro.ipc.Responder
Writes a response message.
A B C D E F G H I J L M N O P R S T U V W 
Skip navigation links

Copyright © 2009–2022 Cloudera. All rights reserved.