diff options
| author | Padma Penumarthy <ppenumar97@yahoo.com> | 2018-03-20 13:44:50 -0700 |
|---|---|---|
| committer | Arina Ielchiieva <arina.yelchiyeva@gmail.com> | 2018-04-06 12:06:49 +0300 |
| commit | 77f5e901370c4c23195ac226d140e8f3eca5f71d (patch) | |
| tree | 3f9144b7fca3c693f72f21dbbee6c87c6d9c223f /exec/java-exec/src/main/java/org/apache/drill/exec/ops | |
| parent | 4f2182e41f4474ca42ae6d572a9c5d5ff274d984 (diff) | |
DRILL-6284: Add operator metrics for batch sizing for flatten
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/ops')
| -rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/ops/OperatorMetricRegistry.java | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/ops/OperatorMetricRegistry.java b/exec/java-exec/src/main/java/org/apache/drill/exec/ops/OperatorMetricRegistry.java index 042433271..b0291548b 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/ops/OperatorMetricRegistry.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/ops/OperatorMetricRegistry.java @@ -21,6 +21,7 @@ import org.apache.drill.exec.physical.impl.ScreenCreator; import org.apache.drill.exec.physical.impl.SingleSenderCreator; import org.apache.drill.exec.physical.impl.aggregate.HashAggTemplate; import org.apache.drill.exec.physical.impl.broadcastsender.BroadcastSenderRootExec; +import org.apache.drill.exec.physical.impl.flatten.FlattenRecordBatch; import org.apache.drill.exec.physical.impl.join.HashJoinBatch; import org.apache.drill.exec.physical.impl.mergereceiver.MergingRecordBatch; import org.apache.drill.exec.physical.impl.partitionsender.PartitionSenderRootExec; @@ -49,6 +50,7 @@ public class OperatorMetricRegistry { register(CoreOperatorType.HASH_JOIN_VALUE, HashJoinBatch.Metric.class); register(CoreOperatorType.EXTERNAL_SORT_VALUE, ExternalSortBatch.Metric.class); register(CoreOperatorType.PARQUET_ROW_GROUP_SCAN_VALUE, ParquetRecordReader.Metric.class); + register(CoreOperatorType.FLATTEN_VALUE, FlattenRecordBatch.Metric.class); } private static void register(final int operatorType, final Class<? extends MetricDef> metricDef) { |