Uses of Interface
org.apache.druid.query.QueryMetrics
Packages that use QueryMetrics
Package
Description
-
Uses of QueryMetrics in org.apache.druid.query
Classes in org.apache.druid.query that implement QueryMetricsModifier and TypeClassDescriptionclassDefaultQueryMetrics<QueryType extends Query<?>>DefaultQueryMetrics is unsafe for use from multiple threads.Methods in org.apache.druid.query that return QueryMetricsModifier and TypeMethodDescriptionQueryMetrics<?> QueryPlus.getQueryMetrics()QueryMetrics<Query<?>> DefaultGenericQueryMetricsFactory.makeMetrics()QueryMetrics<Query<?>> DefaultGenericQueryMetricsFactory.makeMetrics(Query<?> query) QueryMetrics<Query<?>> GenericQueryMetricsFactory.makeMetrics()Creates aQueryMetricswhich doesn't have predefined QueryMetrics subclass.QueryMetrics<Query<?>> GenericQueryMetricsFactory.makeMetrics(Query<?> query) Creates aQueryMetricsfor query, which doesn't have predefined QueryMetrics subclass.QueryMetrics<? super Query<Object>> QueryLogicCompatToolChest.makeMetrics(Query<Object> query) abstract QueryMetrics<? super QueryType> QueryToolChest.makeMetrics(QueryType query) Creates aQueryMetricsobject that is used to generate metrics for this specific query type.static <T> QueryMetrics<?> DruidMetrics.makeRequestMetrics(GenericQueryMetricsFactory queryMetricsFactory, QueryToolChest<T, Query<T>> toolChest, Query<T> query, String remoteAddr) DefaultQueryMetrics.reportBackPressureTime(long timeNs) QueryMetrics.reportBackPressureTime(long timeNs) Registers "time that channel is unreadable (backpressure)" metric.DefaultQueryMetrics.reportBitmapConstructionTime(long timeNs) QueryMetrics.reportBitmapConstructionTime(long timeNs) Reports the time spent constructing bitmap fromfilterBundle(FilterBundle.BundleInfo)of the query.DefaultQueryMetrics.reportCpuTime(long timeNs) QueryMetrics.reportCpuTime(long timeNs) Registers "cpu time" metric.protected QueryMetrics<QueryType> DefaultQueryMetrics.reportMetric(String metricName, Number value) DefaultQueryMetrics.reportNodeBytes(long byteCount) QueryMetrics.reportNodeBytes(long byteCount) Registers "node bytes" metric.DefaultQueryMetrics.reportNodeTime(long timeNs) QueryMetrics.reportNodeTime(long timeNs) Registers "node time" metric.DefaultQueryMetrics.reportNodeTimeToFirstByte(long timeNs) QueryMetrics.reportNodeTimeToFirstByte(long timeNs) Registers "time to first byte" metric.DefaultQueryMetrics.reportParallelMergeFastestPartitionTime(long timeNs) QueryMetrics.reportParallelMergeFastestPartitionTime(long timeNs) Reports broker "wall" time in nanoseconds for the fastest parallel merge sequence partition to be 'initialized', where 'initialized' is time to the first result batch is populated from data servers and merging can begin.DefaultQueryMetrics.reportParallelMergeInputRows(long numRows) QueryMetrics.reportParallelMergeInputRows(long numRows) Reports total number of input rows processed by the broker during parallel merge.DefaultQueryMetrics.reportParallelMergeInputSequences(long numSequences) QueryMetrics.reportParallelMergeInputSequences(long numSequences) Reports total number of input sequences processed by the broker during parallel merge.DefaultQueryMetrics.reportParallelMergeOutputRows(long numRows) QueryMetrics.reportParallelMergeOutputRows(long numRows) Reports broker total number of output rows after merging and combining input sequences (should be less than or equal to the value supplied toreportParallelMergeInputRows(long).DefaultQueryMetrics.reportParallelMergeParallelism(int parallelism) QueryMetrics.reportParallelMergeParallelism(int parallelism) Reports number of parallel tasks the broker used to process the query during parallel merge.DefaultQueryMetrics.reportParallelMergeSlowestPartitionTime(long timeNs) QueryMetrics.reportParallelMergeSlowestPartitionTime(long timeNs) Reports broker "wall" time in nanoseconds for the slowest parallel merge sequence partition to be 'initialized', where 'initialized' is time to the first result batch is populated from data servers and merging can begin.DefaultQueryMetrics.reportParallelMergeTaskCount(long numTasks) QueryMetrics.reportParallelMergeTaskCount(long numTasks) Reports broker total number of fork join pool tasks required to complete queryDefaultQueryMetrics.reportParallelMergeTotalCpuTime(long timeNs) QueryMetrics.reportParallelMergeTotalCpuTime(long timeNs) Reports broker total CPU time in nanoseconds where fork join merge combine tasks were doing workDefaultQueryMetrics.reportParallelMergeTotalTime(long timeNs) QueryMetrics.reportParallelMergeTotalTime(long timeNs) Reports broker total "wall" time in nanoseconds from parallel merge start sequence creation to total consumption.DefaultQueryMetrics.reportPreFilteredRows(long numRows) QueryMetrics.reportPreFilteredRows(long numRows) Reports the number of rows to scan in the segment after applyingfilterBundle(FilterBundle.BundleInfo).DefaultQueryMetrics.reportQueriedSegmentCount(long segmentCount) QueryMetrics.reportQueriedSegmentCount(long segmentCount) Registers "segments queried count" metric.DefaultQueryMetrics.reportQueryBytes(long byteCount) QueryMetrics.reportQueryBytes(long byteCount) Registers "query bytes" metric.DefaultQueryMetrics.reportQueryTime(long timeNs) QueryMetrics.reportQueryTime(long timeNs) Registers "query time" metric.DefaultQueryMetrics.reportResultCachePoll(boolean hit) QueryMetrics.reportResultCachePoll(boolean hit) Emits iff a given query polled the result-level cache and the success of that operation.DefaultQueryMetrics.reportSegmentAndCacheTime(long timeNs) QueryMetrics.reportSegmentAndCacheTime(long timeNs) Registers "segmentAndCache time" metric.DefaultQueryMetrics.reportSegmentRows(long numRows) QueryMetrics.reportSegmentRows(long numRows) Reports the total number of rows in the processed segment.DefaultQueryMetrics.reportSegmentTime(long timeNs) QueryMetrics.reportSegmentTime(long timeNs) Registers "segment time" metric.DefaultQueryMetrics.reportWaitTime(long timeNs) QueryMetrics.reportWaitTime(long timeNs) Registers "wait time" metric.Constructor parameters in org.apache.druid.query with type arguments of type QueryMetricsModifierConstructorDescriptionMetricsEmittingQueryRunner(ServiceEmitter emitter, QueryToolChest<T, ? extends Query<T>> queryToolChest, QueryRunner<T> queryRunner, ObjLongConsumer<? super QueryMetrics<?>> reportMetric, Consumer<QueryMetrics<?>> applyCustomDimensions) MetricsEmittingQueryRunner(ServiceEmitter emitter, QueryToolChest<T, ? extends Query<T>> queryToolChest, QueryRunner<T> queryRunner, ObjLongConsumer<? super QueryMetrics<?>> reportMetric, Consumer<QueryMetrics<?>> applyCustomDimensions) -
Uses of QueryMetrics in org.apache.druid.query.datasourcemetadata
Methods in org.apache.druid.query.datasourcemetadata that return QueryMetricsModifier and TypeMethodDescriptionQueryMetrics<Query<?>> DataSourceQueryQueryToolChest.makeMetrics(DataSourceMetadataQuery query) -
Uses of QueryMetrics in org.apache.druid.query.groupby
Subinterfaces of QueryMetrics in org.apache.druid.query.groupbyClasses in org.apache.druid.query.groupby that implement QueryMetricsMethods in org.apache.druid.query.groupby with parameters of type QueryMetricsModifier and TypeMethodDescriptionstatic CursorBuildSpecGroupingEngine.makeCursorBuildSpec(GroupByQuery query, QueryMetrics<?> queryMetrics) -
Uses of QueryMetrics in org.apache.druid.query.metadata
Methods in org.apache.druid.query.metadata that return QueryMetricsModifier and TypeMethodDescriptionQueryMetrics<Query<?>> SegmentMetadataQueryQueryToolChest.makeMetrics(SegmentMetadataQuery query) -
Uses of QueryMetrics in org.apache.druid.query.operator
Methods in org.apache.druid.query.operator that return QueryMetricsModifier and TypeMethodDescriptionQueryMetrics<? super WindowOperatorQuery> WindowOperatorQueryQueryToolChest.makeMetrics(WindowOperatorQuery query) -
Uses of QueryMetrics in org.apache.druid.query.scan
Methods in org.apache.druid.query.scan that return QueryMetricsModifier and TypeMethodDescriptionQueryMetrics<Query<?>> ScanQueryQueryToolChest.makeMetrics(ScanQuery query) Methods in org.apache.druid.query.scan with parameters of type QueryMetricsModifier and TypeMethodDescriptionstatic CursorBuildSpecScanQueryEngine.makeCursorBuildSpec(ScanQuery query, QueryMetrics<?> queryMetrics) ScanQueryEngine.process(ScanQuery query, Segment segment, ResponseContext responseContext, QueryMetrics<?> queryMetrics) -
Uses of QueryMetrics in org.apache.druid.query.search
Subinterfaces of QueryMetrics in org.apache.druid.query.searchClasses in org.apache.druid.query.search that implement QueryMetricsModifier and TypeClassDescriptionclassThis class is implemented with delegation to another QueryMetrics for compatibility, see "Making subinterfaces of QueryMetrics for emitting custom dimensions and/or metrics for specific query types" section inQueryMetricsjavadoc.Methods in org.apache.druid.query.search that return QueryMetricsModifier and TypeMethodDescriptionDefaultSearchQueryMetrics.reportBackPressureTime(long timeNs) DefaultSearchQueryMetrics.reportBitmapConstructionTime(long timeNs) DefaultSearchQueryMetrics.reportCpuTime(long timeNs) DefaultSearchQueryMetrics.reportNodeBytes(long byteCount) DefaultSearchQueryMetrics.reportNodeTime(long timeNs) DefaultSearchQueryMetrics.reportNodeTimeToFirstByte(long timeNs) DefaultSearchQueryMetrics.reportParallelMergeFastestPartitionTime(long timeNs) DefaultSearchQueryMetrics.reportParallelMergeInputRows(long numRows) DefaultSearchQueryMetrics.reportParallelMergeInputSequences(long numSequences) DefaultSearchQueryMetrics.reportParallelMergeOutputRows(long numRows) DefaultSearchQueryMetrics.reportParallelMergeParallelism(int parallelism) DefaultSearchQueryMetrics.reportParallelMergeSlowestPartitionTime(long timeNs) DefaultSearchQueryMetrics.reportParallelMergeTaskCount(long numTasks) DefaultSearchQueryMetrics.reportParallelMergeTotalCpuTime(long timeNs) DefaultSearchQueryMetrics.reportParallelMergeTotalTime(long timeNs) DefaultSearchQueryMetrics.reportPreFilteredRows(long numRows) DefaultSearchQueryMetrics.reportQueriedSegmentCount(long segmentCount) DefaultSearchQueryMetrics.reportQueryBytes(long byteCount) DefaultSearchQueryMetrics.reportQueryTime(long timeNs) DefaultSearchQueryMetrics.reportResultCachePoll(boolean hit) DefaultSearchQueryMetrics.reportSegmentAndCacheTime(long timeNs) DefaultSearchQueryMetrics.reportSegmentRows(long numRows) DefaultSearchQueryMetrics.reportSegmentTime(long timeNs) DefaultSearchQueryMetrics.reportWaitTime(long timeNs) Constructors in org.apache.druid.query.search with parameters of type QueryMetrics -
Uses of QueryMetrics in org.apache.druid.query.timeboundary
Methods in org.apache.druid.query.timeboundary that return QueryMetricsModifier and TypeMethodDescriptionQueryMetrics<Query<?>> TimeBoundaryQueryQueryToolChest.makeMetrics(TimeBoundaryQuery query) -
Uses of QueryMetrics in org.apache.druid.query.timeseries
Subinterfaces of QueryMetrics in org.apache.druid.query.timeseriesModifier and TypeInterfaceDescriptioninterfaceSpecialization ofQueryMetricsforTimeseriesQuery.Classes in org.apache.druid.query.timeseries that implement QueryMetricsMethods in org.apache.druid.query.timeseries with parameters of type QueryMetricsModifier and TypeMethodDescriptionstatic CursorBuildSpecTimeseriesQueryEngine.makeCursorBuildSpec(TimeseriesQuery query, QueryMetrics<?> queryMetrics) -
Uses of QueryMetrics in org.apache.druid.query.topn
Subinterfaces of QueryMetrics in org.apache.druid.query.topnClasses in org.apache.druid.query.topn that implement QueryMetricsMethods in org.apache.druid.query.topn with parameters of type QueryMetricsModifier and TypeMethodDescriptionstatic CursorBuildSpecTopNQueryEngine.makeCursorBuildSpec(TopNQuery query, QueryMetrics<?> queryMetrics) -
Uses of QueryMetrics in org.apache.druid.segment
Methods in org.apache.druid.segment that return QueryMetricsModifier and TypeMethodDescriptionQueryMetrics<?> CursorBuildSpec.CursorBuildSpecBuilder.getQueryMetrics()QueryMetrics<?> CursorBuildSpec.getQueryMetrics()Methods in org.apache.druid.segment with parameters of type QueryMetricsModifier and TypeMethodDescriptionCursorBuildSpec.CursorBuildSpecBuilder.setQueryMetrics(QueryMetrics<?> queryMetrics) Constructors in org.apache.druid.segment with parameters of type QueryMetricsModifierConstructorDescriptionCursorBuildSpec(Filter filter, org.joda.time.Interval interval, Set<String> physicalColumns, VirtualColumns virtualColumns, List<String> groupingColumns, List<AggregatorFactory> aggregators, List<OrderBy> preferredOrdering, QueryContext queryContext, QueryMetrics<?> queryMetrics)