blob: 3f61e28b15335f66aa112006f8932b3b655dec89 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
|
/**
* ============LICENSE_START=======================================================
* org.onap.aai
* ================================================================================
* Copyright © 2017 AT&T Intellectual Property. All rights reserved.
* Copyright © 2017 Amdocs
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
* ============LICENSE_END=========================================================
*
* ECOMP is a trademark and service mark of AT&T Intellectual Property.
*/
package org.openecomp.sa.searchdbabstraction.util;
import com.fasterxml.jackson.core.JsonProcessingException;
import org.json.simple.JSONArray;
import org.json.simple.JSONObject;
import org.openecomp.sa.searchdbabstraction.entity.AggregationBucket;
import org.openecomp.sa.searchdbabstraction.entity.AggregationResult;
import java.util.Iterator;
import java.util.Set;
public class AggregationParsingUtil {
public static AggregationResult[] parseAggregationResults(JSONObject aggregations)
throws JsonProcessingException {
// Obtain the set of aggregation names
Set keySet = aggregations.keySet();
AggregationResult[] aggResults = new AggregationResult[keySet.size()];
int index = 0;
for (Iterator it = keySet.iterator(); it.hasNext(); ) {
String key = (String) it.next();
AggregationResult aggResult = new AggregationResult();
aggResult.setName(key);
JSONObject bucketsOrNested = (JSONObject) aggregations.get(key);
Object buckets = bucketsOrNested.get("buckets");
if (buckets == null) {
// we have a nested
Number count = (Number) bucketsOrNested.remove("doc_count");
aggResult.setCount(count);
AggregationResult[] nestedResults = parseAggregationResults(bucketsOrNested);
aggResult.setNestedAggregations(nestedResults);
} else {
AggregationBucket[] aggBuckets = parseAggregationBuckets((JSONArray) buckets);
aggResult.setBuckets(aggBuckets);
}
aggResults[index] = aggResult;
index++;
}
return aggResults;
}
private static AggregationBucket[] parseAggregationBuckets(JSONArray buckets)
throws JsonProcessingException {
AggregationBucket[] aggBuckets = new AggregationBucket[buckets.size()];
for (int i = 0; i < buckets.size(); i++) {
AggregationBucket aggBucket = new AggregationBucket();
JSONObject bucketContent = (JSONObject) buckets.get(i);
Object key = bucketContent.remove("key");
aggBucket.setKey(key);
Object formatted = bucketContent.remove("key_as_string");
if (formatted != null) {
aggBucket.setFormattedKey((String) formatted);
}
Object count = bucketContent.remove("doc_count");
if (count != null) {
aggBucket.setCount((Number) count);
}
bucketContent.remove("from");
bucketContent.remove("from_as_string");
bucketContent.remove("to");
bucketContent.remove("to_as_string");
if (!bucketContent.entrySet().isEmpty()) {
// we have results from sub-aggregation
AggregationResult[] subResult = parseAggregationResults(bucketContent);
if (subResult != null) {
aggBucket.setSubAggregationResult(subResult);
}
}
aggBuckets[i] = aggBucket;
}
return aggBuckets;
}
}
|
