com.splicemachine.stream.handlers

Class OpenHandler

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

com.splicemachine.stream.handlers.OpenHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

@ChannelHandler.Sharable
public class OpenHandler
extends io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

We are using Kryo for serialization message between spark and the Olap Server. This handler is going to simply take the current pipeline and add 2 standard channels to encode a kryo object and decode a kryo object. Also it is going to add the main channel handler in the pipleline

See Also:

StreamListenerServer, ResultStreamer

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
OpenHandler(io.netty.channel.ChannelInboundHandlerAdapter listener)

Method Summary

Modifier and Type	Method and Description
void	initChannel(io.netty.channel.socket.SocketChannel ch)

Methods inherited from class io.netty.channel.ChannelInitializer

channelRegistered, exceptionCaught, handlerAdded

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

handlerRemoved, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.channel.ChannelHandler

handlerRemoved

Constructor Detail

OpenHandler

public OpenHandler(io.netty.channel.ChannelInboundHandlerAdapter listener)

Method Detail

initChannel

public void initChannel(io.netty.channel.socket.SocketChannel ch)
                 throws java.lang.Exception

Specified by:

initChannel in class io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

Throws:

java.lang.Exception