Package org.apache.drill.exec.rpc.data

Class DataClient

java.lang.Object

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

org.apache.drill.exec.rpc.BasicClient<BitData.RpcType,DataClientConnection,BitData.BitClientHandshake,BitData.BitServerHandshake>

org.apache.drill.exec.rpc.data.DataClient

All Implemented Interfaces:

Closeable, AutoCloseable

public class DataClient
extends BasicClient<BitData.RpcType,DataClientConnection,BitData.BitClientHandshake,BitData.BitServerHandshake>

Nested Class Summary

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	Description
DataClient(CoordinationProtos.DrillbitEndpoint remoteEndpoint, org.apache.drill.exec.rpc.data.DataConnectionConfig config, ReconnectingConnection<DataClientConnection,BitData.BitClientHandshake>.CloseHandlerCreator closeHandlerFactory)

Method Summary

Modifier and Type	Method	Description
protected io.netty.util.concurrent.GenericFutureListener<io.netty.channel.ChannelFuture>	getCloseHandler(io.netty.channel.socket.SocketChannel ch, DataClientConnection clientConnection)
ProtobufLengthDecoder	getDecoder(BufferAllocator allocator)
com.google.protobuf.MessageLite	getResponseDefaultInstance(int rpcType)
protected void	handle(DataClientConnection connection, int rpcType, io.netty.buffer.ByteBuf pBody, io.netty.buffer.ByteBuf dBody, ResponseSender sender)
protected DataClientConnection	initRemoteConnection(io.netty.channel.socket.SocketChannel channel)
protected void	prepareSaslHandshake(RpcConnectionHandler<DataClientConnection> connectionHandler, List<String> serverAuthMechanisms)	Creates various instances needed to start the SASL handshake.
protected List<String>	validateHandshake(BitData.BitServerHandshake handshake)

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

close, connectAsClient, finalizeConnection, hasPing, isActive, isAuthComplete, isSslEnabled, send, send, send, setAuthComplete, setAutoRead, setSslChannel, setupSSL, startSaslHandshake

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 Details

DataClient

public DataClient(CoordinationProtos.DrillbitEndpoint remoteEndpoint,
 org.apache.drill.exec.rpc.data.DataConnectionConfig config,
 ReconnectingConnection<DataClientConnection,BitData.BitClientHandshake>.CloseHandlerCreator closeHandlerFactory)

Method Details

initRemoteConnection

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

Overrides:

initRemoteConnection in class BasicClient<BitData.RpcType,DataClientConnection,BitData.BitClientHandshake,BitData.BitServerHandshake>

getCloseHandler

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

Overrides:

getCloseHandler in class RpcBus<BitData.RpcType,DataClientConnection>

getResponseDefaultInstance

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

Specified by:

getResponseDefaultInstance in class RpcBus<BitData.RpcType,DataClientConnection>

Throws:

RpcException

handle

protected void handle(DataClientConnection connection,
 int rpcType,
 io.netty.buffer.ByteBuf pBody,
 io.netty.buffer.ByteBuf dBody,
 ResponseSender sender)
               throws RpcException

Specified by:

handle in class RpcBus<BitData.RpcType,DataClientConnection>

Throws:

RpcException

prepareSaslHandshake

protected void prepareSaslHandshake(RpcConnectionHandler<DataClientConnection> connectionHandler,
 List<String> serverAuthMechanisms)

Description copied from class: BasicClient

Creates various instances needed to start the SASL handshake. This is called from BasicClient.validateHandshake(MessageLite) if authentication is required from server side.

Specified by:

prepareSaslHandshake in class BasicClient<BitData.RpcType,DataClientConnection,BitData.BitClientHandshake,BitData.BitServerHandshake>

Parameters:

connectionHandler - - Connection handler used by client's to know about success/failure conditions.

serverAuthMechanisms - - List of auth mechanisms configured on server side

validateHandshake

protected List<String> validateHandshake(BitData.BitServerHandshake handshake)
                                  throws RpcException

Specified by:

validateHandshake in class BasicClient<BitData.RpcType,DataClientConnection,BitData.BitClientHandshake,BitData.BitServerHandshake>

Throws:

RpcException

getDecoder

public ProtobufLengthDecoder getDecoder(BufferAllocator allocator)

Specified by:

getDecoder in class BasicClient<BitData.RpcType,DataClientConnection,BitData.BitClientHandshake,BitData.BitServerHandshake>