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

Class DataClientConnection

java.lang.Object

org.apache.drill.exec.rpc.AbstractRemoteConnection

org.apache.drill.exec.rpc.AbstractClientConnection

org.apache.drill.exec.rpc.data.DataClientConnection

All Implemented Interfaces:

AutoCloseable, ClientConnection, ConnectionThrottle, EncryptionContext, RemoteConnection

public class DataClientConnection
extends AbstractClientConnection

Field Summary

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

saslCodec

Constructor Summary

Constructors

Constructor	Description
DataClientConnection(io.netty.channel.socket.SocketChannel channel, DataClient client, EncryptionContext encryptionContextImpl)

Method Summary

Modifier and Type	Method	Description
void	decConnectionCounter()
boolean	equals(Object obj)
BufferAllocator	getAllocator()
protected org.slf4j.Logger	getLogger()
int	hashCode()
void	incConnectionCounter()
<SEND extends com.google.protobuf.MessageLite, RECEIVE extends com.google.protobuf.MessageLite> void	send(RpcOutcomeListener<RECEIVE> outcomeListener, BitData.RpcType rpcType, SEND protobufBody, Class<RECEIVE> clazz, io.netty.buffer.ByteBuf... dataBodies)

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

channelClosed, disposeSaslClient, getSaslClient, setSaslClient

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

addSecurityHandlers, blockOnNotWritable, close, createNewRpcListener, getAndRemoveRpcOutcome, getChannel, getEncryptionCtxtString, getMaxWrappedSize, getName, getRemoteAddress, getWrapSizeLimit, inEventLoop, isActive, isEncryptionEnabled, recordRemoteFailure, setAutoRead, setEncryption, setMaxWrappedSize, setWrapSizeLimit

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.rpc.ConnectionThrottle

setAutoRead

Methods inherited from interface org.apache.drill.exec.rpc.EncryptionContext

getEncryptionCtxtString, getMaxWrappedSize, getWrapSizeLimit, isEncryptionEnabled, setEncryption, setMaxWrappedSize, setWrapSizeLimit

Methods inherited from interface org.apache.drill.exec.rpc.RemoteConnection

addSecurityHandlers, blockOnNotWritable, close, createNewRpcListener, getAndRemoveRpcOutcome, getChannel, getName, getRemoteAddress, inEventLoop, isActive, recordRemoteFailure

Constructor Details

DataClientConnection

public DataClientConnection(io.netty.channel.socket.SocketChannel channel,
 DataClient client,
 EncryptionContext encryptionContextImpl)

Method Details

getAllocator

public BufferAllocator getAllocator()

send

public <SEND extends com.google.protobuf.MessageLite,
RECEIVE extends com.google.protobuf.MessageLite>
void send(RpcOutcomeListener<RECEIVE> outcomeListener,
 BitData.RpcType rpcType,
 SEND protobufBody,
 Class<RECEIVE> clazz,
 io.netty.buffer.ByteBuf... dataBodies)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

getLogger

protected org.slf4j.Logger getLogger()

Specified by:

getLogger in class AbstractClientConnection

incConnectionCounter

public void incConnectionCounter()

Specified by:

incConnectionCounter in class AbstractRemoteConnection

decConnectionCounter

public void decConnectionCounter()

Specified by:

decConnectionCounter in class AbstractRemoteConnection