Uses of Class
org.apache.drill.exec.ops.OperatorStats
Package
Description
-
Uses of OperatorStats in org.apache.drill.exec.ops
Modifier and TypeMethodDescriptionOperatorContext.getStats()
Drill statistics mechanism.OperatorStats.mergeMetrics
(OperatorStats from) OperatorStats merger - to merge stats from other OperatorStats this is needed in case some processing is multithreaded that needs to have separate OperatorStats to deal with WARN - this will only work for metrics that can be addedFragmentStats.newOperatorStats
(OpProfileDef profileDef, BufferAllocator allocator) Creates a new holder for operator statistics within this holder for fragment statistics.Modifier and TypeMethodDescriptionvoid
FragmentStats.addOperatorStats
(OperatorStats stats) OperatorStats.mergeMetrics
(OperatorStats from) OperatorStats merger - to merge stats from other OperatorStats this is needed in case some processing is multithreaded that needs to have separate OperatorStats to deal with WARN - this will only work for metrics that can be addedFragmentContext.newOperatorContext
(PhysicalOperator popConfig, OperatorStats stats) FragmentContextImpl.newOperatorContext
(PhysicalOperator popConfig, OperatorStats stats) FragmentContextInterface.newOperatorContext
(PhysicalOperator popConfig, OperatorStats stats) ModifierConstructorDescriptionOperatorStats
(OperatorStats original, boolean isClean) Copy constructor to be able to create a copy of existing stats object shell and use it independently this is useful if stats have to be updated in different threads, since it is not really possible to update such stats as waitNanos, setupNanos and processingNanos across threads -
Uses of OperatorStats in org.apache.drill.exec.physical.impl
-
Uses of OperatorStats in org.apache.drill.exec.physical.impl.common
Modifier and TypeMethodDescriptionvoid
SpilledState.updateCycle
(OperatorStats operatorStats, T spilledPartition, SpilledState.Updater updater) Update the current spill cycle. -
Uses of OperatorStats in org.apache.drill.exec.physical.impl.materialize
-
Uses of OperatorStats in org.apache.drill.exec.physical.impl.partitionsender
Modifier and TypeMethodDescriptionprotected PartitionerTemplate.OutgoingRecordBatch
PartitionerTemplate.newOutgoingRecordBatch
(OperatorStats stats, HashPartitionSender operator, AccountingDataTunnel tunnel, FragmentContext context, BufferAllocator allocator, int oppositeMinorFragmentId) Shim method to be overridden in plain-old Java mode by the subclass to instantiate the generated inner class.void
Partitioner.setup
(ExchangeFragmentContext context, RecordBatch incoming, HashPartitionSender popConfig, OperatorStats stats, OperatorContext oContext, ClassGenerator<?> cg, int start, int count) final void
PartitionerTemplate.setup
(ExchangeFragmentContext context, RecordBatch incoming, HashPartitionSender popConfig, OperatorStats stats, OperatorContext oContext, ClassGenerator<?> cg, int start, int end) ModifierConstructorDescriptionOutgoingRecordBatch
(OperatorStats stats, HashPartitionSender operator, AccountingDataTunnel tunnel, FragmentContext context, BufferAllocator allocator, int oppositeMinorFragmentId) -
Uses of OperatorStats in org.apache.drill.exec.physical.impl.xsort
-
Uses of OperatorStats in org.apache.drill.exec.record
-
Uses of OperatorStats in org.apache.drill.exec.store.dfs
ModifierConstructorDescriptionDrillFileSystem
(org.apache.hadoop.conf.Configuration fsConf, OperatorStats operatorStats) DrillFSDataInputStream
(org.apache.hadoop.fs.FSDataInputStream in, OperatorStats operatorStats) DrillFSDataInputStream
(org.apache.hadoop.fs.FSDataInputStream in, OperatorStats operatorStats, OpenFileTracker openFileTracker) -
Uses of OperatorStats in org.apache.drill.exec.store.parquet