- 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
-