org.graylog.plugins.views.search.elasticsearch.searchtypes.pivot

Class ESPivotSeriesSpecHandler<SPEC_TYPE extends SeriesSpec,AGGREGATION_RESULT extends io.searchbox.core.search.aggregation.Aggregation>

java.lang.Object

org.graylog.plugins.views.search.elasticsearch.searchtypes.pivot.ESPivotSeriesSpecHandler<SPEC_TYPE,AGGREGATION_RESULT>

All Implemented Interfaces:

SeriesSpecHandler<SPEC_TYPE,org.elasticsearch.search.aggregations.AggregationBuilder,io.searchbox.core.SearchResult,AGGREGATION_RESULT,ESPivot,ESGeneratedQueryContext>

Direct Known Subclasses:

ESAverageHandler, ESCardinalityHandler, ESCountHandler, ESMaxHandler, ESMinHandler, ESPercentilesHandler, ESStdDevHandler, ESSumHandler, ESSumOfSquaresHandler, ESVarianceHandler

public abstract class ESPivotSeriesSpecHandler<SPEC_TYPE extends SeriesSpec,AGGREGATION_RESULT extends io.searchbox.core.search.aggregation.Aggregation>
extends Object
implements SeriesSpecHandler<SPEC_TYPE,org.elasticsearch.search.aggregations.AggregationBuilder,io.searchbox.core.SearchResult,AGGREGATION_RESULT,ESPivot,ESGeneratedQueryContext>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ESPivotSeriesSpecHandler.Value

Constructor Summary

Constructors

Constructor and Description
ESPivotSeriesSpecHandler()

Method Summary

Modifier and Type	Method and Description
protected ESPivot.AggTypes	aggTypes(ESGeneratedQueryContext queryContext, Pivot pivot)
abstract Stream<ESPivotSeriesSpecHandler.Value>	doHandleResult(Pivot pivot, SPEC_TYPE seriesSpec, io.searchbox.core.SearchResult searchResult, AGGREGATION_RESULT aggregation_result, ESPivot searchTypeHandler, ESGeneratedQueryContext queryContext)
protected io.searchbox.core.search.aggregation.Aggregation	extractAggregationFromResult(Pivot pivot, PivotSpec spec, io.searchbox.core.search.aggregation.MetricAggregation aggregations, ESGeneratedQueryContext queryContext)
Stream<ESPivotSeriesSpecHandler.Value>	handleResult(Pivot pivot, SeriesSpec seriesSpec, Object queryResult, Object aggregationResult, SearchTypeHandler searchTypeHandler, GeneratedQueryContext queryContext)
protected void	record(ESGeneratedQueryContext queryContext, Pivot pivot, PivotSpec spec, String name, Class<? extends io.searchbox.core.search.aggregation.Aggregation> aggregationClass)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.graylog.plugins.views.search.searchtypes.pivot.SeriesSpecHandler

createAggregation, doCreateAggregation

Constructor Detail

ESPivotSeriesSpecHandler

public ESPivotSeriesSpecHandler()

Method Detail

aggTypes

protected ESPivot.AggTypes aggTypes(ESGeneratedQueryContext queryContext,
                                    Pivot pivot)

record

protected void record(ESGeneratedQueryContext queryContext,
                      Pivot pivot,
                      PivotSpec spec,
                      String name,
                      Class<? extends io.searchbox.core.search.aggregation.Aggregation> aggregationClass)

extractAggregationFromResult

protected io.searchbox.core.search.aggregation.Aggregation extractAggregationFromResult(Pivot pivot,
                                                                                        PivotSpec spec,
                                                                                        io.searchbox.core.search.aggregation.MetricAggregation aggregations,
                                                                                        ESGeneratedQueryContext queryContext)

handleResult

public Stream<ESPivotSeriesSpecHandler.Value> handleResult(Pivot pivot,
                                                           SeriesSpec seriesSpec,
                                                           Object queryResult,
                                                           Object aggregationResult,
                                                           SearchTypeHandler searchTypeHandler,
                                                           GeneratedQueryContext queryContext)

Specified by:

handleResult in interface SeriesSpecHandler<SPEC_TYPE extends SeriesSpec,org.elasticsearch.search.aggregations.AggregationBuilder,io.searchbox.core.SearchResult,AGGREGATION_RESULT extends io.searchbox.core.search.aggregation.Aggregation,ESPivot,ESGeneratedQueryContext>

doHandleResult

public abstract Stream<ESPivotSeriesSpecHandler.Value> doHandleResult(Pivot pivot,
                                                                      SPEC_TYPE seriesSpec,
                                                                      io.searchbox.core.SearchResult searchResult,
                                                                      AGGREGATION_RESULT aggregation_result,
                                                                      ESPivot searchTypeHandler,
                                                                      ESGeneratedQueryContext queryContext)

Specified by:

doHandleResult in interface SeriesSpecHandler<SPEC_TYPE extends SeriesSpec,org.elasticsearch.search.aggregations.AggregationBuilder,io.searchbox.core.SearchResult,AGGREGATION_RESULT extends io.searchbox.core.search.aggregation.Aggregation,ESPivot,ESGeneratedQueryContext>