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

Class ESPivotBucketSpecHandler<SPEC_TYPE extends BucketSpec,AGGREGATION_RESULT extends io.searchbox.core.search.aggregation.Aggregation>

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

ESTimeHandler, ESValuesHandler

public abstract class ESPivotBucketSpecHandler<SPEC_TYPE extends BucketSpec,AGGREGATION_RESULT extends io.searchbox.core.search.aggregation.Aggregation>
extends Object
implements BucketSpecHandler<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	ESPivotBucketSpecHandler.Bucket

Constructor Summary

Constructors

Constructor and Description
ESPivotBucketSpecHandler()

Method Summary

Modifier and Type	Method and Description
protected ESPivot.AggTypes	aggTypes(ESGeneratedQueryContext queryContext, Pivot pivot)
abstract Stream<ESPivotBucketSpecHandler.Bucket>	doHandleResult(Pivot pivot, SPEC_TYPE bucketSpec, 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<ESPivotBucketSpecHandler.Bucket>	handleResult(Pivot pivot, BucketSpec bucketSpec, 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.BucketSpecHandler

createAggregation, doCreateAggregation

Constructor Detail

ESPivotBucketSpecHandler

public ESPivotBucketSpecHandler()

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<ESPivotBucketSpecHandler.Bucket> handleResult(Pivot pivot,
                                                            BucketSpec bucketSpec,
                                                            Object queryResult,
                                                            Object aggregationResult,
                                                            SearchTypeHandler searchTypeHandler,
                                                            GeneratedQueryContext queryContext)

Specified by:

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

doHandleResult

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

Specified by:

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