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

Class DataRpcMetrics

java.lang.Object

org.apache.drill.exec.rpc.AbstractRpcMetrics

org.apache.drill.exec.rpc.data.DataRpcMetrics

All Implemented Interfaces:

RpcMetrics

public class DataRpcMetrics
extends AbstractRpcMetrics

Holds metrics related to bit data rpc layer

Field Summary

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

ALLOCATOR_METRICS_PREFIX, CONNECTION_COUNTER_PREFIX, useEncryptedCounter

Method Summary

Modifier and Type	Method	Description
void	addConnectionCount()
void	decConnectionCount()
long	getEncryptedConnectionCount()
static RpcMetrics	getInstance()
long	getUnEncryptedConnectionCount()
void	initialize(boolean useEncryptedCounter, BufferAllocator allocator)	Should only be called when first access to getInstance is made.

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

registerAllocatorMetrics

Methods inherited from class java.lang.Object

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

Method Details

getInstance

public static RpcMetrics getInstance()

initialize

public void initialize(boolean useEncryptedCounter,
 BufferAllocator allocator)

Should only be called when first access to getInstance is made. In this case inside DataConnectionCreator. DataServerConnection and DataClientConnection using the singleton instance should not call initialize.

Specified by:

initialize in class AbstractRpcMetrics

Parameters:

useEncryptedCounter -

allocator -

addConnectionCount

public void addConnectionCount()

decConnectionCount

public void decConnectionCount()

getEncryptedConnectionCount

public long getEncryptedConnectionCount()

getUnEncryptedConnectionCount

public long getUnEncryptedConnectionCount()