Package 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	Description
DataTunnel(DataConnectionManager manager)

Method Summary

Modifier and Type	Method	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 Details

DataTunnel

public DataTunnel(DataConnectionManager manager)

Method Details

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)