org.apache.drill.exec.ops

Interface ExchangeFragmentContext

All Superinterfaces:

AutoCloseable, FragmentContext, UdfUtilities

All Known Subinterfaces:

ExecutorFragmentContext, RootFragmentContext

All Known Implementing Classes:

FragmentContextImpl

public interface ExchangeFragmentContext
extends FragmentContext

This provides the resources required by an exchange operator.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.ops.FragmentContext

FragmentContext.ExecutorState

Field Summary

Fields inherited from interface org.apache.drill.exec.ops.UdfUtilities

INJECTABLE_GETTER_METHODS

Method Summary

Modifier and Type	Method and Description
IncomingBuffers	getBuffers()
Controller	getController()
AccountingDataTunnel	getDataTunnel(CoordinationProtos.DrillbitEndpoint endpoint)
AccountingUserConnection	getUserDataTunnel()
void	waitForSendComplete()

Methods inherited from interface org.apache.drill.exec.ops.FragmentContext

addRuntimeFilter, close, getAliasRegistryProvider, getAllocator, getCompiler, getConfig, getExecutionControls, getExecutor, getExecutorState, getFragIdString, getFullRootSchema, getFunctionRegistry, getHandle, getImplementationClass, getImplementationClass, getImplementationClass, getImplementationClass, getManagedBuffer, getManagedBuffer, getManagedBufferManager, getMetastoreRegistry, getNewChildAllocator, getOptions, getQueryId, getQueryIdString, getQueryUserName, getRuntimeFilter, getRuntimeFilter, getScanDecodeExecutor, getScanExecutor, getSQLStatementType, isImpersonationEnabled, newOperatorContext, newOperatorContext, replace, requestMemory

Methods inherited from interface org.apache.drill.exec.ops.UdfUtilities

getConstantValueHolder, getContextInformation, getPartitionExplorer

Method Detail

waitForSendComplete

void waitForSendComplete()

getDataTunnel

AccountingDataTunnel getDataTunnel(CoordinationProtos.DrillbitEndpoint endpoint)

getUserDataTunnel

AccountingUserConnection getUserDataTunnel()

getController

Controller getController()

getBuffers

IncomingBuffers getBuffers()