File tree Expand file tree Collapse file tree 1 file changed +0
-21
lines changed
src/main/kotlin/org/opensearch/commons/alerting/aggregation/bucketselectorext Expand file tree Collapse file tree 1 file changed +0
-21
lines changed Original file line number Diff line number Diff line change @@ -2,8 +2,6 @@ package org.opensearch.commons.alerting.aggregation.bucketselectorext
22
33import org.apache.lucene.util.BytesRef
44import org.opensearch.common.io.stream.StreamInput
5- import org.opensearch.common.io.stream.StreamOutput
6- import org.opensearch.commons.alerting.aggregation.bucketselectorext.BucketSelectorExtAggregationBuilder.Companion.NAME
75import org.opensearch.script.BucketAggregationSelectorScript
86import org.opensearch.script.Script
97import org.opensearch.search.DocValueFormat
@@ -59,25 +57,6 @@ class BucketSelectorExtAggregator : SiblingPipelineAggregator {
5957 }
6058 }
6159
62- @Throws(IOException ::class )
63- override fun doWriteTo (out : StreamOutput ) {
64- out .writeString(name)
65- script.writeTo(out )
66- gapPolicy.writeTo(out )
67- out .writeGenericValue(bucketsPathsMap)
68- out .writeString(parentBucketPath)
69- if (bucketSelectorExtFilter != null ) {
70- out .writeBoolean(true )
71- bucketSelectorExtFilter!! .writeTo(out )
72- } else {
73- out .writeBoolean(false )
74- }
75- }
76-
77- override fun getWriteableName (): String {
78- return NAME .preferredName
79- }
80-
8160 override fun doReduce (aggregations : Aggregations , reduceContext : InternalAggregation .ReduceContext ): InternalAggregation {
8261 val parentBucketPathList = AggregationPath .parse(parentBucketPath).pathElementsAsStringList
8362 var subAggregations: Aggregations = aggregations
You can’t perform that action at this time.
0 commit comments