Elasticsearch 자바 API(17)집계 집합 함수
14940 단어 Elasticsearch자바
Min 취 합 편집
다음은 어떻게 사용 합 니까? Min Aggregation 자바 API 와.
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
MetricsAggregationBuilder aggregation =
AggregationBuilders
.min("agg")
.field("height");
취 합 반응 편집 사용
집합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.metrics.min.Min;
// sr is here your SearchResponse object
Min agg = sr.getAggregations().get("agg");
double value = agg.getValue();
Max 취 합 편집
다음은 Max Aggregation 을 어떻게 사용 하 는 지. 자바 API 와.
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
MetricsAggregationBuilder aggregation =
AggregationBuilders
.max("agg")
.field("height");
취 합 반응 편집 사용
집합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.metrics.max.Max;
// sr is here your SearchResponse object
Max agg = sr.getAggregations().get("agg");
double value = agg.getValue();
Sum 취 합 편집
다음은 Sum Aggregation 을 어떻게 사용 하 는 지. 자바 API 와.
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
MetricsAggregationBuilder aggregation =
AggregationBuilders
.sum("agg")
.field("height");
취 합 반응 편집 사용
집합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.metrics.sum.Sum;
// sr is here your SearchResponse object
Sum agg = sr.getAggregations().get("agg");
double value = agg.getValue();
Avg 취 합 편집
Avg 취 합 과 자바 API 를 어떻게 사용 하 는 지 알 아 보 겠 습 니 다.
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
MetricsAggregationBuilder aggregation =
AggregationBuilders
.avg("agg")
.field("height");
취 합 반응 편집 사용
집합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.metrics.avg.Avg;
// sr is here your SearchResponse object
Avg agg = sr.getAggregations().get("agg");
double value = agg.getValue();
Stats 취 합 편집
다음은 Stats Aggregation 을 어떻게 사용 하 는 지 자바 API 와.
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
MetricsAggregationBuilder aggregation =
AggregationBuilders
.stats("agg")
.field("height");
취 합 반응 편집 사용
집합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.metrics.stats.Stats;
// sr is here your SearchResponse object
Stats agg = sr.getAggregations().get("agg");
double min = agg.getMin();
double max = agg.getMax();
double avg = agg.getAvg();
double sum = agg.getSum();
long count = agg.getCount();
확장 데이터 집합 편집
다음은 Extended Stats Aggregation 을 어떻게 사용 하 는 지 자바 API 와.
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
MetricsAggregationBuilder aggregation =
AggregationBuilders
.extendedStats("agg")
.field("height");
취 합 반응 편집 사용
집합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.metrics.stats.extended.ExtendedStats;
// sr is here your SearchResponse object
ExtendedStats agg = sr.getAggregations().get("agg");
double min = agg.getMin();
double max = agg.getMax();
double avg = agg.getAvg();
double sum = agg.getSum();
long count = agg.getCount();
double stdDeviation = agg.getStdDeviation();
double sumOfSquares = agg.getSumOfSquares();
double variance = agg.getVariance();
값 계산 취 합 편집
다음은 Value Count Aggregation 을 어떻게 사용 하 는 지. 자바 API 와.
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
MetricsAggregationBuilder aggregation =
AggregationBuilders
.count("agg")
.field("height");
취 합 반응 편집 사용
집합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.metrics.valuecount.ValueCount;
// sr is here your SearchResponse object
ValueCount agg = sr.getAggregations().get("agg");
long value = agg.getValue();
퍼센트 집합 편집
다음은 Percentile Aggregation 을 어떻게 사용 하 는 지 자바 API 와.
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
MetricsAggregationBuilder aggregation =
AggregationBuilders
.percentiles("agg")
.field("height");
기본 값 대신 100%자릿수 를 제공 할 수 있 습 니 다.
MetricsAggregationBuilder aggregation =
AggregationBuilders
.percentiles("agg")
.field("height")
.percentiles(1.0, 5.0, 10.0, 20.0, 30.0, 75.0, 95.0, 99.0);
취 합 반응 편집 으로 취 합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.metrics.percentiles.Percentile;
import org.elasticsearch.search.aggregations.metrics.percentiles.Percentiles;
// sr is here your SearchResponse object
Percentiles agg = sr.getAggregations().get("agg");
// For each entry
for (Percentile entry : agg) {
double percent = entry.getPercent(); // Percent
double value = entry.getValue(); // Value
logger.info("percent [{}], value [{}]", percent, value);
}
기본적으로 이것 은 첫 번 째 예 가 생 길 것 이다.
percent [1.0], value [0.814338896154595]
percent [5.0], value [0.8761912455821302]
percent [25.0], value [1.173346540141847]
percent [50.0], value [1.5432023318692198]
percent [75.0], value [1.923915462033674]
percent [95.0], value [2.2273644908535335]
percent [99.0], value [2.284989339108279]
100%순위 집합 편집
다음은 Percentile Ranks Aggregation 과 자바 API 를 어떻게 사용 하 는 지 입 니 다.
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
MetricsAggregationBuilder aggregation =
AggregationBuilders
.percentileRanks("agg")
.field("height")
.percentiles(1.24, 1.91, 2.22);
취 합 반응 편집 사용
집합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.metrics.percentiles.Percentile;
import org.elasticsearch.search.aggregations.metrics.percentiles.PercentileRanks;
// sr is here your SearchResponse object
PercentileRanks agg = sr.getAggregations().get("agg");
// For each entry
for (Percentile entry : agg) {
double percent = entry.getPercent(); // Percent
double value = entry.getValue(); // Value
logger.info("percent [{}], value [{}]", percent, value);
}
이것 은 주로 생산 될 것 이다.
percent [29.664353095090945], value [1.24]
percent [73.9335313461868], value [1.91]
percent [94.40095147327283], value [2.22]
기수 집합 편집
다음은 Cardinality Aggregation 을 어떻게 사용 하 는 지. 자바 API 와.
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
MetricsAggregationBuilder aggregation =
AggregationBuilders
.cardinality("agg")
.field("tags");
취 합 반응 편집 사용
집합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.metrics.cardinality.Cardinality;
// sr is here your SearchResponse object
Cardinality agg = sr.getAggregations().get("agg");
long value = agg.getValue();
기수 집합 편집
다음은 지리 적 경계 집합 과 자바 API 를 어떻게 사용 하 는 지 입 니 다.
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
GeoBoundsBuilder aggregation =
AggregationBuilders
.geoBounds("agg")
.field("address.location")
.wrapLongitude(true);
취 합 반응 편집 으로 취 합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.metrics.geobounds.GeoBounds;
// sr is here your SearchResponse object
GeoBounds agg = sr.getAggregations().get("agg");
GeoPoint bottomRight = agg.bottomRight();
GeoPoint topLeft = agg.topLeft();
logger.info("bottomRight {}, topLeft {}", bottomRight, topLeft);
이것 은 주로 생산 될 것 이다.
bottomRight [40.70500764381921, 13.952946866893775], topLeft [53.49603022435221, -4.190029308156676]
조회 수 최고 취 합 편집
다음은 Top Hits Aggregation 과 Java API 를 어떻게 사용 하 는 지 입 니 다.
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
AggregationBuilder aggregation =
AggregationBuilders
.terms("agg").field("gender")
.subAggregation(
AggregationBuilders.topHits("top")
);
대부분의 선택 등 표준 검색 을 사용 할 수 있 습 니 다.
from
,
size
,
sort
,
highlight
,
explain
…
AggregationBuilder aggregation =
AggregationBuilders
.terms("agg").field("gender")
.subAggregation(
AggregationBuilders.topHits("top")
.setExplain(true)
.setSize(1)
.setFrom(10)
);
취 합 반응 편집 사용
집합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.bucket.terms.Terms;
import org.elasticsearch.search.aggregations.metrics.tophits.TopHits;
// sr is here your SearchResponse object
Terms agg = sr.getAggregations().get("agg");
// For each entry
for (Terms.Bucket entry : agg.getBuckets()) {
String key = entry.getKey(); // bucket key
long docCount = entry.getDocCount(); // Doc count
logger.info("key [{}], doc_count [{}]", key, docCount);
// We ask for top_hits for each bucket
TopHits topHits = entry.getAggregations().get("top");
for (SearchHit hit : topHits.getHits().getHits()) {
logger.info(" -> id [{}], _source [{}]", hit.getId(), hit.getSourceAsString());
}
}
기본적으로 이것 은 첫 번 째 예 가 생 길 것 이다.
key [male], doc_count [5107]
-> id [AUnzSZze9k7PKXtq04x2], _source [{"gender":"male",...}]
-> id [AUnzSZzj9k7PKXtq04x4], _source [{"gender":"male",...}]
-> id [AUnzSZzl9k7PKXtq04x5], _source [{"gender":"male",...}]
key [female], doc_count [4893]
-> id [AUnzSZzM9k7PKXtq04xy], _source [{"gender":"female",...}]
-> id [AUnzSZzp9k7PKXtq04x8], _source [{"gender":"female",...}]
-> id [AUnzSZ0W9k7PKXtq04yS], _source [{"gender":"female",...}]
스 크 립 트 화 된 게이지 집합 편집
다음은 스 크 립 트 화 된 게이지 집합 과 자바 API 를 어떻게 사용 하 는 지 입 니 다.
Groovy 를 클래스 경로 에 추가 하 는 것 을 잊 지 마 십시오.Groovy 스 크 립 트 를 내장 형 데이터 노드(예 를 들 어 유닛 테스트)에서 실행 하려 면.예 를 들 어 Maven 을 사용 하여 이러한 의존성
pom.xml
파일 을 추가 합 니 다.
org.codehaus.groovy
groovy-all
2.3.2
indy
취 합 준비 편집 요청
집합 을 만 드 는 방법 에 대한 예 가 있 습 니 다.
MetricsAggregationBuilder aggregation =
AggregationBuilders
.scriptedMetric("agg")
.initScript("_agg['heights'] = []")
.mapScript(new Script("if (doc['gender'].value == \"male\") " +
"{ _agg.heights.add(doc['height'].value) } " +
"else " +
"{ _agg.heights.add(-1 * doc['height'].value) }"));
너 도 하나 지정 할 수 있어.
combine
스 크 립 트 는 조각 마다 실 행 됩 니 다:
MetricsAggregationBuilder aggregation =
AggregationBuilders
.scriptedMetric("agg")
.initScript(new Script("_agg['heights'] = []"))
.mapScript(new Script("if (doc['gender'].value == \"male\") " +
"{ _agg.heights.add(doc['height'].value) } " +
"else " +
"{ _agg.heights.add(-1 * doc['height'].value) }"))
.combineScript(new Script("heights_sum = 0; for (t in _agg.heights) { heights_sum += t }; return heights_sum"));
너 도 하나 지정 할 수 있어.
reduce
스 크 립 트 는 요청 한 노드 를 실행 합 니 다:
MetricsAggregationBuilder aggregation =
AggregationBuilders
.scriptedMetric("agg")
.initScript(new Script("_agg['heights'] = []"))
.mapScript(new Script("if (doc['gender'].value == \"male\") " +
"{ _agg.heights.add(doc['height'].value) } " +
"else " +
"{ _agg.heights.add(-1 * doc['height'].value) }"))
.combineScript(new Script("heights_sum = 0; for (t in _agg.heights) { heights_sum += t }; return heights_sum"))
.reduceScript(new Script("heights_sum = 0; for (a in _aggs) { heights_sum += a }; return heights_sum"));
취 합 반응 편집 사용
집합 정의 클래스 가 져 오기:
import org.elasticsearch.search.aggregations.bucket.terms.Terms;
import org.elasticsearch.search.aggregations.metrics.tophits.TopHits;
// sr is here your SearchResponse object
ScriptedMetric agg = sr.getAggregations().get("agg");
Object scriptedResult = agg.aggregation();
logger.info("scriptedResult [{}]", scriptedResult);
결 과 는 스 크 립 트 에 달 려 있 습 니 다.
첫 번 째 예시 에 대해 이것 은 주로 생산 될 것 이다.
scriptedResult object [ArrayList]
scriptedResult [ {
"heights" : [ 1.122218480146643, -1.8148918111233887, -1.7626731575142909, ... ]
}, {
"heights" : [ -0.8046067304119863, -2.0785486707864553, -1.9183567430207953, ... ]
}, {
"heights" : [ 2.092635728868694, 1.5697545960886536, 1.8826954461968808, ... ]
}, {
"heights" : [ -2.1863201099468403, 1.6328549117346856, -1.7078288405893842, ... ]
}, {
"heights" : [ 1.6043904836424177, -2.0736538674414025, 0.9898266674373053, ... ]
} ]
두 번 째 예 는 다음 과 같다.
scriptedResult object [ArrayList]
scriptedResult [-41.279615707402876,
-60.88007362339038,
38.823270659734256,
14.840192739445632,
11.300902755741326]
마지막 예 는 다음 과 같 습 니 다.
scriptedResult object [Double]
scriptedResult [2.171917696507009]
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Embulk를 사용하여 ElasticCloud로 보내기Embulk에서 ElasticCloud에 보낼 수 있을까라고 생각비망록도 겸해 기술을 남깁니다 Embulk 설치 ElasticCloud (14 일 체험판) brew라면 아래 명령 입력 파일 만들기 파일 내용 seed...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.