import org.elasticsearch.search.facet.Facets; //导入依赖的package包/类
public Facets getFacets() {
	return facets;
}
 

import org.elasticsearch.search.facet.Facets; //导入依赖的package包/类
@Test
public void testTopicFacets() throws Exception {
    DateTime now = new DateTime(DateTimeZones.UTC);
    Broadcast broadcast1 = new Broadcast(Id.valueOf(1), now, now.plusHours(1));

    Broadcast broadcast2 = new Broadcast(Id.valueOf(1), now.plusHours(2), now.plusHours(3));

    Tag topic1 = new Tag(Id.valueOf(1), 1.0f, Boolean.TRUE, Tag.Relationship.ABOUT);
    Tag topic2 = new Tag(Id.valueOf(2), 1.0f, Boolean.TRUE, Tag.Relationship.ABOUT);

    Item item1 = new Item("uri1", "curie1", Publisher.METABROADCAST);
    item1.addBroadcast(broadcast1);
    item1.setId(Id.valueOf(1));
    item1.addTopicRef(topic1);
    item1.addTopicRef(topic2);
    Item item2 = new Item("uri2", "curie2", Publisher.METABROADCAST);
    item2.addBroadcast(broadcast1);
    item2.setId(Id.valueOf(2));
    item2.addTopicRef(topic1);
    Item item3 = new Item("uri3", "curie3", Publisher.METABROADCAST);
    item3.addBroadcast(broadcast2);
    item3.setId(Id.valueOf(3));
    item3.addTopicRef(topic2);

    contentIndexer.index(item1);
    contentIndexer.index(item2);
    contentIndexer.index(item3);

    refresh(esClient.client());

    ListenableActionFuture<SearchResponse> futureResult = esClient.client()
            .prepareSearch(EsSchema.CONTENT_INDEX)
            .setQuery(QueryBuilders.nestedQuery(
                    EsContent.BROADCASTS,
                    QueryBuilders.rangeQuery(EsBroadcast.TRANSMISSION_TIME)
                            .from(now.minusHours(1).toDate())
                            .to(now.plusHours(1).toDate())
            ))
            .addFacet(FacetBuilders.termsFacet("topicFacet")
                    .nested(EsContent.TOPICS + "." + EsTopicMapping.TOPIC)
                    .field(EsContent.TOPICS + "." + EsTopicMapping.TOPIC_ID))
            .execute();

    SearchResponse result = futureResult.actionGet(5, TimeUnit.SECONDS);
    Facets facets = result.getFacets();
    List<? extends Entry> terms = facets.facet(TermsFacet.class, "topicFacet").getEntries();

    assertEquals(2, terms.size());
    assertEquals("1", terms.get(0).getTerm().string());
    assertEquals(2, terms.get(0).getCount());
    assertEquals("2", terms.get(1).getTerm().string());
    assertEquals(1, terms.get(1).getCount());
}
 

import org.elasticsearch.search.facet.Facets; //导入依赖的package包/类
public void setFacets(Facets facets) {
	this.facets = facets;
}