org.apache.drill.exec.rpc.data

Class DataTunnel

java.lang.Object

org.apache.drill.exec.rpc.data.DataTunnel

public class DataTunnel
extends Object

Constructor Summary

Constructors

Constructor and Description
DataTunnel(DataConnectionManager manager)

Method Summary

Modifier and Type	Method and Description
void	sendRecordBatch(RpcOutcomeListener<BitData.AckWithCredit> outcomeListener, FragmentWritableBatch batch)
void	sendRuntimeFilter(RpcOutcomeListener<BitData.AckWithCredit> outcomeListener, RuntimeFilterWritable runtimeFilter)
void	setTestInjectionControls(ControlsInjector testInjector, ExecutionControls testControls, org.slf4j.Logger testLogger) Once a DataTunnel is created, clients of DataTunnel can pass injection controls to enable setting injections at pre-defined places.

Methods inherited from class java.lang.Object

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

Constructor Detail

DataTunnel

public DataTunnel(DataConnectionManager manager)

Method Detail

setTestInjectionControls

public void setTestInjectionControls(ControlsInjector testInjector,
                                     ExecutionControls testControls,
                                     org.slf4j.Logger testLogger)

Once a DataTunnel is created, clients of DataTunnel can pass injection controls to enable setting injections at pre-defined places. Currently following injection sites are available. 1. In method sendRecordBatch(RpcOutcomeListener, FragmentWritableBatch), an interruptible pause injection is available before acquiring the sending slot. Site name is: "data-tunnel-send-batch-wait-for-interrupt"

Parameters:

testInjector -

testControls -

testLogger -

sendRecordBatch

public void sendRecordBatch(RpcOutcomeListener<BitData.AckWithCredit> outcomeListener,
                            FragmentWritableBatch batch)

sendRuntimeFilter

public void sendRuntimeFilter(RpcOutcomeListener<BitData.AckWithCredit> outcomeListener,
                              RuntimeFilterWritable runtimeFilter)