org.apache.drill.exec.rpc.data

Class DataServer

java.lang.Object

org.apache.drill.exec.rpc.RpcBus<T,SC>

org.apache.drill.exec.rpc.BasicServer<BitData.RpcType,DataServerConnection>

org.apache.drill.exec.rpc.data.DataServer

All Implemented Interfaces:

Closeable, AutoCloseable

public class DataServer
extends BasicServer<BitData.RpcType,DataServerConnection>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.rpc.BasicServer

BasicServer.ServerHandshakeHandler<T extends com.google.protobuf.MessageLite>

Nested classes/interfaces inherited from class org.apache.drill.exec.rpc.RpcBus

RpcBus.ChannelClosedHandler, RpcBus.InboundHandler

Field Summary

Fields inherited from class org.apache.drill.exec.rpc.RpcBus

local, remote, rpcConfig

Constructor Summary

Constructors

Constructor and Description
DataServer(org.apache.drill.exec.rpc.data.DataConnectionConfig config)

Method Summary

Modifier and Type	Method and Description
protected io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>	getCloseHandler(io.netty.channel.socket.SocketChannel ch, DataServerConnection connection)
protected ProtobufLengthDecoder	getDecoder(BufferAllocator allocator, OutOfMemoryHandler outOfMemoryHandler)
protected BasicServer.ServerHandshakeHandler<BitData.BitClientHandshake>	getHandshakeHandler(DataServerConnection connection)
protected OutOfMemoryHandler	getOutOfMemoryHandler()
com.google.protobuf.MessageLite	getResponseDefaultInstance(int rpcType)
protected DataServerConnection	initRemoteConnection(io.netty.channel.socket.SocketChannel channel)

Methods inherited from class org.apache.drill.exec.rpc.BasicServer

bind, close, closeSSL, handle, isSslEnabled, setSslChannel, setupSSL

Methods inherited from class org.apache.drill.exec.rpc.RpcBus

get, send, send, send, setAddresses

Methods inherited from class java.lang.Object

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

Constructor Detail

DataServer

public DataServer(org.apache.drill.exec.rpc.data.DataConnectionConfig config)

Method Detail

getResponseDefaultInstance

public com.google.protobuf.MessageLite getResponseDefaultInstance(int rpcType)
                                                           throws RpcException

Specified by:

getResponseDefaultInstance in class BasicServer<BitData.RpcType,DataServerConnection>

Throws:

RpcException

getCloseHandler

protected io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture> getCloseHandler(io.netty.channel.socket.SocketChannel ch,
                                                                                                         DataServerConnection connection)

Overrides:

getCloseHandler in class RpcBus<BitData.RpcType,DataServerConnection>

initRemoteConnection

protected DataServerConnection initRemoteConnection(io.netty.channel.socket.SocketChannel channel)

Overrides:

initRemoteConnection in class BasicServer<BitData.RpcType,DataServerConnection>

getHandshakeHandler

protected BasicServer.ServerHandshakeHandler<BitData.BitClientHandshake> getHandshakeHandler(DataServerConnection connection)

Specified by:

getHandshakeHandler in class BasicServer<BitData.RpcType,DataServerConnection>

getOutOfMemoryHandler

protected OutOfMemoryHandler getOutOfMemoryHandler()

Overrides:

getOutOfMemoryHandler in class BasicServer<BitData.RpcType,DataServerConnection>

getDecoder

protected ProtobufLengthDecoder getDecoder(BufferAllocator allocator,
                                           OutOfMemoryHandler outOfMemoryHandler)

Specified by:

getDecoder in class BasicServer<BitData.RpcType,DataServerConnection>