ExchangeFragmentContext (Drill : 1.21.2-SNAPSHOT API)

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

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, getDrillbitContext, getPartitionExplorer, getResultSetLoader

Method Details
- waitForSendComplete
  
  void waitForSendComplete()
- getDataTunnel
  
  AccountingDataTunnel getDataTunnel(CoordinationProtos.DrillbitEndpoint endpoint)
- getUserDataTunnel
  
  AccountingUserConnection getUserDataTunnel()
- getController
  
  Controller getController()
- getBuffers
  
  IncomingBuffers getBuffers()