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 and Description
AccountingDataTunnel(DataTunnel tunnel, SendingAccountor sendingAccountor, RpcOutcomeListener<BitData.AckWithCredit> statusHandler)

Method Summary

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

AccountingDataTunnel

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

Method Detail

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).