org.apache.drill.exec.rpc.data

Class DataServerConnection

java.lang.Object

org.apache.drill.exec.rpc.AbstractRemoteConnection

org.apache.drill.exec.rpc.AbstractServerConnection<DataServerConnection>

org.apache.drill.exec.rpc.data.DataServerConnection

All Implemented Interfaces:

AutoCloseable, ConnectionThrottle, EncryptionContext, RemoteConnection, ServerConnection<DataServerConnection>

public class DataServerConnection
extends AbstractServerConnection<DataServerConnection>

Field Summary

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

saslCodec

Method Summary

Modifier and Type	Method and Description
void	decConnectionCounter()
protected org.slf4j.Logger	getLogger()
void	incConnectionCounter()

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

changeHandlerTo, channelClosed, disposeSaslServer, finalizeSaslSession, getAllocator, getCurrentHandler, getSaslServer, initSaslServer, setEncryption, setMaxWrappedSize

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

Methods inherited from class java.lang.Object

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

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

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

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

Method Detail

getLogger

protected org.slf4j.Logger getLogger()

Specified by:

getLogger in class AbstractServerConnection<DataServerConnection>

incConnectionCounter

public void incConnectionCounter()

Specified by:

incConnectionCounter in class AbstractRemoteConnection

decConnectionCounter

public void decConnectionCounter()

Specified by:

decConnectionCounter in class AbstractRemoteConnection