Package org.apache.drill.exec.ops

Class AccountingDataTunnel

java.lang.Object

org.apache.drill.exec.ops.AccountingDataTunnel

public class AccountingDataTunnel
extends Object

Wrapper around a DataTunnel that tracks the status of batches sent to to other Drillbits.

Constructor Summary

Constructors

Constructor	Description
AccountingDataTunnel(DataTunnel tunnel, SendingAccountor sendingAccountor, RpcOutcomeListener<BitData.AckWithCredit> statusHandler)

Method Summary

Modifier and Type	Method	Description
void	sendRecordBatch(FragmentWritableBatch batch)
void	sendRuntimeFilter(RuntimeFilterWritable batch)
void	setTestInjectionControls(ControlsInjector testInjector, ExecutionControls testControls, org.slf4j.Logger testLogger)	See DataTunnel.setTestInjectionControls(ControlsInjector, ExecutionControls, Logger).

Methods inherited from class java.lang.Object

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

Constructor Details

AccountingDataTunnel

public AccountingDataTunnel(DataTunnel tunnel,
 SendingAccountor sendingAccountor,
 RpcOutcomeListener<BitData.AckWithCredit> statusHandler)

Method Details

sendRecordBatch

public void sendRecordBatch(FragmentWritableBatch batch)

sendRuntimeFilter

public void sendRuntimeFilter(RuntimeFilterWritable batch)

setTestInjectionControls

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

See DataTunnel.setTestInjectionControls(ControlsInjector, ExecutionControls, Logger).