Package org.apache.drill.exec.ops
package org.apache.drill.exec.ops
-
ClassDescriptionWrapper around a
DataTunnel
that tracks the status of batches sent to to other Drillbits.Wrapper around aUserClientConnection
that tracks the status of batches sent to User.Common implementation for both the test and production versions of the fragment context.Implementation ofOperatorContext
that provides services needed by most run-time operators.Manages a list ofDrillBuf
s that can be reallocated as needed.Consumer<T>Provides query context information (such as query start time, query user, default schema etc.) for UDFs.Listener that keeps track of the status of batches sent, and updates the SendingAccountor when status is received for each batchThis provides the resources required by an exchange operator.The context that is used by a Drillbit in classes like theFragmentExecutor
.Provides the resources required by a non-exchange operator to execute.This is the core Context which implements all the Context interfaces:FragmentContext
: A context provided to non-exchange operators.ExchangeFragmentContext
: A context provided to exchange operators.RootFragmentContext
: A context provided to fragment roots.ExecutorFragmentContext
: A context used by the Drillbit. The interfaces above expose resources to varying degrees.Fragment context interface: separates implementation from definition.Holds statistics of a particular (minor) fragment.Interface that defines a metric.Per-operator services available for operator implementations.Registry of operator metrics.Interface for updating a statistic.Utility methods, formerly on the OperatorContext class, that work with operators.Indicates that an external source has cancelled the query.Provides services needed by theFragmentExecutor
.Account for whether all messages sent have been completed.Listener that keeps track of the status of batches sent, and updates the SendingAccountor when status is received for each batchDefines the query state and shared resources available to UDFs through injectables.Contains context information about view expansion(s) in a query.