本文整理汇总了Java中org.elasticsearch.search.facet.Facet类的典型用法代码示例。如果您正苦于以下问题：Java Facet类的具体用法？Java Facet怎么用？Java Facet使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Facet类属于org.elasticsearch.search.facet包，在下文中一共展示了Facet类的8个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: reduce
import org.elasticsearch.search.facet.Facet; //导入依赖的package包/类
@Override
public Facet reduce(ReduceContext reduceContext) {
List<Facet> facets = reduceContext.facets();
GeoHashCellFacet geoHashCellFacet = (GeoHashCellFacet) facets.get(0);
for (int i = 1; i < facets.size(); i++) {
Facet facet = facets.get(i);
if (facet instanceof GeoHashCellFacet) {
GeoHashCellFacet hashCellFacet = (GeoHashCellFacet) facet;
geoHashCellFacet.results = geoHashCellFacet.results.reduce(hashCellFacet.results);
}
}
return geoHashCellFacet;
}
开发者ID:gornik，项目名称:gorgeo，代码行数:18，代码来源:GeoHashCellFacet.java
示例2: myReduce
import org.elasticsearch.search.facet.Facet; //导入依赖的package包/类
/**
* Takes a list of facets and returns a new facet containing the merged data from all of them.
*
* @param name the facet name
* @param facets the facets
* @return the resulting reduced facet
*/
public Facet myReduce(final String name, final List<Facet> facets) {
final Set<String> reducedStrings = new HashSet<String>();
for(final Facet facet : facets) {
final InternalTermListFacet itlf = (InternalTermListFacet) facet;
for(final Object obj : itlf.strings) {
reducedStrings.add(obj.toString());
}
}
String[] strArr = reducedStrings.toArray( new String[ reducedStrings.size() ] );
if(sort)
Arrays.sort( strArr );
return new InternalTermListFacet(name, strArr, sort );
}
开发者ID:endgameinc，项目名称:elasticsearch-term-plugin，代码行数:25，代码来源:InternalTermListFacet.java
示例3: getFacetsFromResult
import org.elasticsearch.search.facet.Facet; //导入依赖的package包/类
static Map<String, FacetResult> getFacetsFromResult(
Map<String, FacetRequest._Fields> facetMap,
Map<String, Facet> elasticFacets) {
// Parse out facets
final Map<String, FacetResult> facetResults = new HashMap<>();
for (final Map.Entry<String, FacetRequest._Fields> entry : facetMap.entrySet()) {
final FacetResult result = new FacetResult();
final Facet response = elasticFacets.get(entry.getKey());
switch (entry.getValue()) {
case DATE_HISTOGRAM_FACET:
result.setDateFacetResult(convertDateHistogramFacetResults((DateHistogramFacet) response));
break;
case FILTER_FACET:
result.setFilterFacetResult(convertFilterFacetResults((FilterFacet) response));
break;
case HISTOGRAM_FACET:
result.setHistogramFacetResult(convertHistogramFacetResults((HistogramFacet) response));
break;
case RANGE_FACET:
result.setRangeFacetResult(convertRangeFacetResults((RangeFacet) response));
break;
case TERMS_FACET:
result.setTermsFacetResult(convertTermsFacetResults((TermsFacet) response));
break;
case STATISTICAL_FACET:
result.setStatisticalFacetResult(convertStatisticalFacetResults((StatisticalFacet) response));
break;
case TERMS_STATS_FACET:
result.setTermsStatsFacetResult(convertTermsStatsFacetResults((TermsStatsFacet) response));
break;
default:
throw new IllegalArgumentException("Facet result has unknown type " + entry.getValue());
}
facetResults.put(entry.getKey(), result);
}
return facetResults;
}
开发者ID:ezbake，项目名称:ezelastic，代码行数:40，代码来源:FacetResultsToThriftConversions.java
示例4: readFacet
import org.elasticsearch.search.facet.Facet; //导入依赖的package包/类
@Override
public Facet readFacet(StreamInput in) throws IOException {
GeoHashCellFacet facet = new GeoHashCellFacet();
facet.readFrom(in);
return facet;
}
开发者ID:gornik，项目名称:gorgeo，代码行数:7，代码来源:GeoHashCellFacet.java
示例5: readFacet
import org.elasticsearch.search.facet.Facet; //导入依赖的package包/类
@Override
public Facet readFacet(StreamInput in) throws IOException {
return readTermListFacet(in);
}
开发者ID:endgameinc，项目名称:elasticsearch-term-plugin，代码行数:5，代码来源:InternalTermListFacet.java
示例6: reduce
import org.elasticsearch.search.facet.Facet; //导入依赖的package包/类
@Override
public Facet reduce(ReduceContext context) {
return myReduce(this.getName(), context.facets());
}
开发者ID:endgameinc，项目名称:elasticsearch-term-plugin，代码行数:5，代码来源:InternalTermListFacet.java
示例7: testSearchById
import org.elasticsearch.search.facet.Facet; //导入依赖的package包/类
@Test
public void testSearchById() {
setIndexTemplate();
indexDoc();
assertTrue(esServer.indexExists(configuration.getStorageIndexNamePrefix() + "-2013-02-11"));
ElasticSearchFrequentlyRelatedItemSearchProcessor searcher = new ElasticSearchFrequentlyRelatedItemSearchProcessor(configuration,new FrequentRelatedSearchRequestBuilder(configuration),RelatedItemNoopGetRepository.INSTANCE);
RelatedItemSearch[] search = new RelatedItemSearch[] {createIdSearch("emmerdale")};
MultiSearchResponse response = searcher.executeSearch(clientFactory.getClient(),search);
assertTrue(response != null);
System.out.println(response);
assertEquals("Did not return the expected 1 search result, for emmerdale search", 1, response.getResponses().length);
System.out.println(response.getResponses()[0].getFailureMessage());
assertTrue("Search Response should not be null", response.getResponses()[0].getResponse() != null);
assertEquals(1,response.getResponses()[0].getResponse().getFacets().getFacets().size());
Facet f = response.getResponses()[0].getResponse().getFacets().getFacets().get(configuration.getStorageFrequentlyRelatedItemsFacetResultsFacetName());
assertTrue(f instanceof TermsFacet);
TermsFacet tf = (TermsFacet)f;
assertEquals(1,tf.getEntries().size());
assertEquals("the bill",tf.getEntries().get(0).getTerm().string());
SearchResultEventWithSearchRequestKey[] results = searcher.processMultiSearchResponse(search,response);
assertTrue(results != null);
assertEquals("Should have a result",1,results.length);
verifyTermsInOutput(results[0].getResponse(),tf);
}
开发者ID:tootedom，项目名称:related，代码行数:39，代码来源:ElasticSearchFrequentlyRelatedItemSearchProcessorTest.java
示例8: testAliasCanBeUsed
import org.elasticsearch.search.facet.Facet; //导入依赖的package包/类
@Test
public void testAliasCanBeUsed() {
System.setProperty(ConfigurationConstants.PROPNAME_STORAGE_INDEX_NAME_ALIAS,"beginningoftheyear");
Configuration configuration = new SystemPropertiesConfiguration();
setIndexTemplate();
indexDoc();
setAlias(configuration);
ElasticSearchFrequentlyRelatedItemSearchProcessor searcher = new ElasticSearchFrequentlyRelatedItemSearchProcessor(configuration,new FrequentRelatedSearchRequestBuilder(configuration),RelatedItemNoopGetRepository.INSTANCE);
RelatedItemSearch[] search = new RelatedItemSearch[] {createIdSearch("emmerdale")};
MultiSearchResponse response = searcher.executeSearch(clientFactory.getClient(),search);
assertTrue(response != null);
System.out.println(response);
assertEquals("Did not return the expected 1 search result, for emmerdale search", 1, response.getResponses().length);
System.out.println(response.getResponses()[0].getFailureMessage());
assertTrue("Search Response should not be null", response.getResponses()[0].getResponse() != null);
assertEquals(1,response.getResponses()[0].getResponse().getFacets().getFacets().size());
Facet f = response.getResponses()[0].getResponse().getFacets().getFacets().get(configuration.getStorageFrequentlyRelatedItemsFacetResultsFacetName());
assertTrue(f instanceof TermsFacet);
TermsFacet tf = (TermsFacet)f;
assertEquals(1,tf.getEntries().size());
assertEquals("the bill",tf.getEntries().get(0).getTerm().string());
SearchResultEventWithSearchRequestKey[] results = searcher.processMultiSearchResponse(search,response);
assertTrue(results != null);
assertEquals("Should have a result",1,results.length);
verifyTermsInOutput(results[0].getResponse(),tf);
}
开发者ID:tootedom，项目名称:related，代码行数:42，代码来源:ElasticSearchFrequentlyRelatedItemSearchProcessorTest.java
注：本文中的org.elasticsearch.search.facet.Facet类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论