Skip navigation links
C D E G I J L N O R S T U W 

C

callback - Variable in class org.apache.avro.ipc.netty.NettyTransceiver.WriteFutureListener
 
channelInactive(ChannelHandlerContext) - Method in class org.apache.avro.ipc.netty.NettyTransceiver.NettyClientAvroHandler
 
channelRead0(ChannelHandlerContext, NettyTransportCodec.NettyDataPack) - Method in class org.apache.avro.ipc.netty.NettyTransceiver.NettyClientAvroHandler
 
close() - Method in class org.apache.avro.ipc.netty.NettyServer
 
close() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
Closes this transceiver and disconnects from the remote peer.
close(boolean) - Method in class org.apache.avro.ipc.netty.NettyTransceiver
Closes this transceiver and disconnects from the remote peer.
createNettyClientAvroHandler() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
Creates a Netty ChannelUpstreamHandler for handling events on the Netty client channel.

D

decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.apache.avro.ipc.netty.NettyTransportCodec.NettyFrameDecoder
decode buffer to NettyDataPack
DEFAULT_CONNECTION_TIMEOUT_MILLIS - Static variable in class org.apache.avro.ipc.netty.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.netty.NettyTransceiver
 

E

encode(ChannelHandlerContext, NettyTransportCodec.NettyDataPack, List<Object>) - Method in class org.apache.avro.ipc.netty.NettyTransportCodec.NettyFrameEncoder
encode msg to ChannelBuffer
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.apache.avro.ipc.netty.NettyTransceiver.NettyClientAvroHandler
 

G

getDatas() - Method in class org.apache.avro.ipc.netty.NettyTransportCodec.NettyDataPack
 
getNumActiveConnections() - Method in class org.apache.avro.ipc.netty.NettyServer
 
getPort() - Method in class org.apache.avro.ipc.netty.NettyServer
 
getRemote() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
 
getRemoteName() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
 
getSerial() - Method in class org.apache.avro.ipc.netty.NettyTransportCodec.NettyDataPack
 

I

isConnected() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
 

J

join() - Method in class org.apache.avro.ipc.netty.NettyServer
 

L

lockChannel() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
Netty channels are thread-safe, so there is no need to acquire locks.

N

NETTY_CONNECT_TIMEOUT_OPTION - Static variable in class org.apache.avro.ipc.netty.NettyTransceiver
 
NETTY_KEEPALIVE_OPTION - Static variable in class org.apache.avro.ipc.netty.NettyTransceiver
 
NETTY_TCP_NODELAY_OPTION - Static variable in class org.apache.avro.ipc.netty.NettyTransceiver
 
NettyClientAvroHandler() - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver.NettyClientAvroHandler
 
NettyDataPack() - Constructor for class org.apache.avro.ipc.netty.NettyTransportCodec.NettyDataPack
 
NettyDataPack(int, List<ByteBuffer>) - Constructor for class org.apache.avro.ipc.netty.NettyTransportCodec.NettyDataPack
 
NettyFrameDecoder() - Constructor for class org.apache.avro.ipc.netty.NettyTransportCodec.NettyFrameDecoder
 
NettyFrameEncoder() - Constructor for class org.apache.avro.ipc.netty.NettyTransportCodec.NettyFrameEncoder
 
NettyServer - Class in org.apache.avro.ipc.netty
A Netty-based RPC Server implementation.
NettyServer(Responder, InetSocketAddress) - Constructor for class org.apache.avro.ipc.netty.NettyServer
 
NettyServer(Responder, InetSocketAddress, Consumer<SocketChannel>) - Constructor for class org.apache.avro.ipc.netty.NettyServer
 
NettyServer(Responder, InetSocketAddress, Consumer<SocketChannel>, Consumer<ServerBootstrap>) - Constructor for class org.apache.avro.ipc.netty.NettyServer
 
NettyServer(Responder, InetSocketAddress, Consumer<SocketChannel>, Consumer<ServerBootstrap>, EventLoopGroup, EventLoopGroup, EventLoopGroup) - Constructor for class org.apache.avro.ipc.netty.NettyServer
 
NettyTransceiver - Class in org.apache.avro.ipc.netty
A Netty-based Transceiver implementation.
NettyTransceiver(InetSocketAddress) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver
Creates a NettyTransceiver, and attempts to connect to the given address.
NettyTransceiver(InetSocketAddress, Integer) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver
Creates a NettyTransceiver, and attempts to connect to the given address.
NettyTransceiver(InetSocketAddress, Consumer<SocketChannel>) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver
Creates a NettyTransceiver, and attempts to connect to the given address.
NettyTransceiver(InetSocketAddress, Integer, Consumer<SocketChannel>) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver
Creates a NettyTransceiver, and attempts to connect to the given address.
NettyTransceiver(InetSocketAddress, Integer, Consumer<SocketChannel>, Consumer<Bootstrap>) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver
Creates a NettyTransceiver, and attempts to connect to the given address.
NettyTransceiver.NettyClientAvroHandler - Class in org.apache.avro.ipc.netty
Avro client handler for the Netty transport
NettyTransceiver.NettyTransceiverThreadFactory - Class in org.apache.avro.ipc.netty
Creates threads with unique names based on a specified name prefix.
NettyTransceiver.WriteFutureListener - Class in org.apache.avro.ipc.netty
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.netty.NettyTransceiver.NettyTransceiverThreadFactory
Creates a NettyTransceiverThreadFactory that creates threads with the specified name.
NettyTransportCodec - Class in org.apache.avro.ipc.netty
Data structure, encoder and decoder classes for the Netty transport.
NettyTransportCodec() - Constructor for class org.apache.avro.ipc.netty.NettyTransportCodec
 
NettyTransportCodec.NettyDataPack - Class in org.apache.avro.ipc.netty
Transport protocol data structure when using Netty.
NettyTransportCodec.NettyFrameDecoder - Class in org.apache.avro.ipc.netty
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.netty
Protocol encoder which converts NettyDataPack which contains the Responder's output List<ByteBuffer> to ChannelBuffer needed by Netty.
newThread(Runnable) - Method in class org.apache.avro.ipc.netty.NettyTransceiver.NettyTransceiverThreadFactory
 

O

operationComplete(ChannelFuture) - Method in class org.apache.avro.ipc.netty.NettyTransceiver.WriteFutureListener
 
org.apache.avro.ipc.netty - package org.apache.avro.ipc.netty
 

R

readBuffers() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
 

S

setDatas(List<ByteBuffer>) - Method in class org.apache.avro.ipc.netty.NettyTransportCodec.NettyDataPack
 
setRemote(Protocol) - Method in class org.apache.avro.ipc.netty.NettyTransceiver
 
setSerial(int) - Method in class org.apache.avro.ipc.netty.NettyTransportCodec.NettyDataPack
 
start() - Method in class org.apache.avro.ipc.netty.NettyServer
 

T

transceive(List<ByteBuffer>) - Method in class org.apache.avro.ipc.netty.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.netty.NettyTransceiver
 

U

unlockChannel() - Method in class org.apache.avro.ipc.netty.NettyTransceiver
Netty channels are thread-safe, so there is no need to acquire locks.

W

writeBuffers(List<ByteBuffer>) - Method in class org.apache.avro.ipc.netty.NettyTransceiver
 
WriteFutureListener(Callback<List<ByteBuffer>>) - Constructor for class org.apache.avro.ipc.netty.NettyTransceiver.WriteFutureListener
Creates a WriteFutureListener that notifies the given callback if an error occurs writing data to the channel.
C D E G I J L N O R S T U W 
Skip navigation links

Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.