Java AnalyzeRequest类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest类的典型用法代码示例。如果您正苦于以下问题：Java AnalyzeRequest类的具体用法？Java AnalyzeRequest怎么用？Java AnalyzeRequest使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

AnalyzeRequest类属于org.elasticsearch.action.admin.indices.analyze包，在下文中一共展示了AnalyzeRequest类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: testParseXContentForAnalyzeRequest

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
public void testParseXContentForAnalyzeRequest() throws Exception {
    XContentParser content = createParser(XContentFactory.jsonBuilder()
        .startObject()
            .field("text", "THIS IS A TEST")
            .field("tokenizer", "keyword")
            .array("filter", "lowercase")
        .endObject());

    AnalyzeRequest analyzeRequest = new AnalyzeRequest("for test");

    RestAnalyzeAction.buildFromContent(content, analyzeRequest);

    assertThat(analyzeRequest.text().length, equalTo(1));
    assertThat(analyzeRequest.text(), equalTo(new String[]{"THIS IS A TEST"}));
    assertThat(analyzeRequest.tokenizer().name, equalTo("keyword"));
    assertThat(analyzeRequest.tokenFilters().size(), equalTo(1));
    for (AnalyzeRequest.NameOrDefinition filter : analyzeRequest.tokenFilters()) {
        assertThat(filter.name, equalTo("lowercase"));
    }
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:21，代码来源:RestAnalyzeActionTests.java

示例2: testTokenizer

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
@Test
public void testTokenizer() throws Exception {
    AnalyzeRequest analyzeRequest = new AnalyzeRequest();
    analyzeRequest.text("My œsophagus caused a débâcle");
    /**
     * whitespace （空白字符）分词器按空白字符 —— 空格、tabs、换行符等等进行简单拆分
     * letter 分词器 ，采用另外一种策略，按照任何非字符进行拆分
     * standard 分词器使用 Unicode 文本分割算法
     */
    analyzeRequest.addTokenFilter("standard");
    analyzeRequest.addCharFilter("asciifolding");
    ActionFuture<AnalyzeResponse> analyzeResponseActionFuture =  client.admin().indices().analyze(analyzeRequest);
    List<AnalyzeResponse.AnalyzeToken> analyzeTokens =  analyzeResponseActionFuture.actionGet().getTokens();
    for (AnalyzeResponse.AnalyzeToken analyzeToken : analyzeTokens){
        System.out.println(analyzeToken.getTerm());
    }
}

开发者ID:felayman，项目名称:elasticsearch-full，代码行数:18，代码来源:AnalyzeDemo.java

示例3: prepareRequest

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {

    AnalyzeRequest analyzeRequest = new AnalyzeRequest(request.param("index"));

    try (XContentParser parser = request.contentOrSourceParamParser()) {
        buildFromContent(parser, analyzeRequest);
    } catch (IOException e) {
        throw new IllegalArgumentException("Failed to parse request body", e);
    }

    return channel -> client.admin().indices().analyze(analyzeRequest, new RestToXContentListener<>(channel));
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:14，代码来源:RestAnalyzeAction.java

示例4: testParseXContentForAnalyzeRequestWithCustomFilters

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
public void testParseXContentForAnalyzeRequestWithCustomFilters() throws Exception {
    XContentParser content = createParser(XContentFactory.jsonBuilder()
        .startObject()
            .field("text", "THIS IS A TEST")
            .field("tokenizer", "keyword")
            .startArray("filter")
                .value("lowercase")
                .startObject()
                    .field("type", "stop")
                    .array("stopwords", "foo", "buzz")
                .endObject()
            .endArray()
            .startArray("char_filter")
                .startObject()
                    .field("type", "mapping")
                    .array("mappings", "ph => f", "qu => q")
                .endObject()
            .endArray()
        .endObject());

    AnalyzeRequest analyzeRequest = new AnalyzeRequest("for test");

    RestAnalyzeAction.buildFromContent(content, analyzeRequest);

    assertThat(analyzeRequest.text().length, equalTo(1));
    assertThat(analyzeRequest.text(), equalTo(new String[]{"THIS IS A TEST"}));
    assertThat(analyzeRequest.tokenizer().name, equalTo("keyword"));
    assertThat(analyzeRequest.tokenFilters().size(), equalTo(2));
    assertThat(analyzeRequest.tokenFilters().get(0).name, equalTo("lowercase"));
    assertThat(analyzeRequest.tokenFilters().get(1).definition, notNullValue());
    assertThat(analyzeRequest.charFilters().size(), equalTo(1));
    assertThat(analyzeRequest.charFilters().get(0).definition, notNullValue());
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:34，代码来源:RestAnalyzeActionTests.java

示例5: testParseXContentForAnalyzeRequestWithUnknownParamThrowsException

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
public void testParseXContentForAnalyzeRequestWithUnknownParamThrowsException() throws Exception {
    AnalyzeRequest analyzeRequest = new AnalyzeRequest("for test");
    XContentParser invalidContent = createParser(XContentFactory.jsonBuilder()
        .startObject()
            .field("text", "THIS IS A TEST")
            .field("unknown", "keyword")
        .endObject());
    IllegalArgumentException e = expectThrows(IllegalArgumentException.class,
            () -> RestAnalyzeAction.buildFromContent(invalidContent, analyzeRequest));
    assertThat(e.getMessage(), startsWith("Unknown parameter [unknown]"));
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:12，代码来源:RestAnalyzeActionTests.java

示例6: testParseXContentForAnalyzeRequestWithInvalidStringExplainParamThrowsException

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
public void testParseXContentForAnalyzeRequestWithInvalidStringExplainParamThrowsException() throws Exception {
    AnalyzeRequest analyzeRequest = new AnalyzeRequest("for test");
    XContentParser invalidExplain = createParser(XContentFactory.jsonBuilder()
        .startObject()
            .field("explain", "fals")
        .endObject());
    IllegalArgumentException e = expectThrows(IllegalArgumentException.class,
        () -> RestAnalyzeAction.buildFromContent(invalidExplain, analyzeRequest));
    assertThat(e.getMessage(), startsWith("explain must be either 'true' or 'false'"));
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:11，代码来源:RestAnalyzeActionTests.java

示例7: testNoIndexAnalyzers

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
public void testNoIndexAnalyzers() throws IOException {
    AnalyzeRequest request = new AnalyzeRequest();
    request.analyzer("standard");
    request.text("the quick brown fox");
    AnalyzeResponse analyze = TransportAnalyzeAction.analyze(request, AllFieldMapper.NAME, null, null, registry, environment);
    List<AnalyzeResponse.AnalyzeToken> tokens = analyze.getTokens();
    assertEquals(4, tokens.size());

    request.analyzer(null);
    request.tokenizer("whitespace");
    request.addTokenFilter("lowercase");
    request.addTokenFilter("word_delimiter");
    request.text("the qu1ck brown fox");
    analyze = TransportAnalyzeAction.analyze(request, AllFieldMapper.NAME, null, randomBoolean() ? indexAnalyzers : null, registry, environment);
    tokens = analyze.getTokens();
    assertEquals(6, tokens.size());
    assertEquals("qu", tokens.get(1).getTerm());
    assertEquals("1", tokens.get(2).getTerm());
    assertEquals("ck", tokens.get(3).getTerm());

    request.analyzer(null);
    request.tokenizer("whitespace");
    request.addCharFilter("html_strip");
    request.addTokenFilter("lowercase");
    request.addTokenFilter("word_delimiter");
    request.text("<p>the qu1ck brown fox</p>");
    analyze = TransportAnalyzeAction.analyze(request, AllFieldMapper.NAME, null, randomBoolean() ? indexAnalyzers : null, registry, environment);
    tokens = analyze.getTokens();
    assertEquals(6, tokens.size());
    assertEquals("the", tokens.get(0).getTerm());
    assertEquals("qu", tokens.get(1).getTerm());
    assertEquals("1", tokens.get(2).getTerm());
    assertEquals("ck", tokens.get(3).getTerm());
    assertEquals("brown", tokens.get(4).getTerm());
    assertEquals("fox", tokens.get(5).getTerm());
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:37，代码来源:TransportAnalyzeActionTests.java

示例8: testFillsAttributes

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
public void testFillsAttributes() throws IOException {
    AnalyzeRequest request = new AnalyzeRequest();
    request.analyzer("standard");
    request.text("the 1 brown fox");
    AnalyzeResponse analyze = TransportAnalyzeAction.analyze(request, AllFieldMapper.NAME, null, null, registry, environment);
    List<AnalyzeResponse.AnalyzeToken> tokens = analyze.getTokens();
    assertEquals(4, tokens.size());
    assertEquals("the", tokens.get(0).getTerm());
    assertEquals(0, tokens.get(0).getStartOffset());
    assertEquals(3, tokens.get(0).getEndOffset());
    assertEquals(0, tokens.get(0).getPosition());
    assertEquals("<ALPHANUM>", tokens.get(0).getType());

    assertEquals("1", tokens.get(1).getTerm());
    assertEquals(4, tokens.get(1).getStartOffset());
    assertEquals(5, tokens.get(1).getEndOffset());
    assertEquals(1, tokens.get(1).getPosition());
    assertEquals("<NUM>", tokens.get(1).getType());

    assertEquals("brown", tokens.get(2).getTerm());
    assertEquals(6, tokens.get(2).getStartOffset());
    assertEquals(11, tokens.get(2).getEndOffset());
    assertEquals(2, tokens.get(2).getPosition());
    assertEquals("<ALPHANUM>", tokens.get(2).getType());

    assertEquals("fox", tokens.get(3).getTerm());
    assertEquals(12, tokens.get(3).getStartOffset());
    assertEquals(15, tokens.get(3).getEndOffset());
    assertEquals(3, tokens.get(3).getPosition());
    assertEquals("<ALPHANUM>", tokens.get(3).getType());
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:32，代码来源:TransportAnalyzeActionTests.java

示例9: testGetIndexAnalyserWithoutIndexAnalyzers

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
public void testGetIndexAnalyserWithoutIndexAnalyzers() throws IOException {
    IllegalArgumentException e = expectThrows(IllegalArgumentException.class,
        () -> TransportAnalyzeAction.analyze(
            new AnalyzeRequest()
                .analyzer("custom_analyzer")
                .text("the qu1ck brown fox-dog"),
            AllFieldMapper.NAME, null, null, registry, environment));
    assertEquals(e.getMessage(), "failed to find global analyzer [custom_analyzer]");
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:10，代码来源:TransportAnalyzeActionTests.java

示例10: testNonPreBuildTokenFilter

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
public void testNonPreBuildTokenFilter() throws IOException {
    AnalyzeRequest request = new AnalyzeRequest();
    request.tokenizer("whitespace");
    request.addTokenFilter("min_hash");
    request.text("the quick brown fox");
    AnalyzeResponse analyze = TransportAnalyzeAction.analyze(request, AllFieldMapper.NAME, null, indexAnalyzers, registry, environment);
    List<AnalyzeResponse.AnalyzeToken> tokens = analyze.getTokens();
    int default_hash_count = 1;
    int default_bucket_size = 512;
    int default_hash_set_size = 1;
    assertEquals(default_hash_count * default_bucket_size * default_hash_set_size, tokens.size());

}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:14，代码来源:TransportAnalyzeActionTests.java

示例11: testAnalyze

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
public void testAnalyze() {
    String analyzeShardAction = AnalyzeAction.NAME + "[s]";
    interceptTransportActions(analyzeShardAction);

    AnalyzeRequest analyzeRequest = new AnalyzeRequest(randomIndexOrAlias());
    analyzeRequest.text("text");
    internalCluster().coordOnlyNodeClient().admin().indices().analyze(analyzeRequest).actionGet();

    clearInterceptedActions();
    assertSameIndices(analyzeRequest, analyzeShardAction);
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:12，代码来源:IndicesRequestIT.java

示例12: handleRequest

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
@Override
public void handleRequest(final RestRequest request, final RestChannel channel, final Client client) {

    String[] texts = request.paramAsStringArrayOrEmptyIfAll("text");

    AnalyzeRequest analyzeRequest = new AnalyzeRequest(request.param("index"));
    analyzeRequest.text(texts);
    analyzeRequest.analyzer(request.param("analyzer"));
    analyzeRequest.field(request.param("field"));
    analyzeRequest.tokenizer(request.param("tokenizer"));
    analyzeRequest.tokenFilters(request.paramAsStringArray("filter", request.paramAsStringArray("token_filter",
        request.paramAsStringArray("token_filters", request.paramAsStringArray("filters", analyzeRequest.tokenFilters())))));
    analyzeRequest.charFilters(request.paramAsStringArray("char_filter", request.paramAsStringArray("char_filters", analyzeRequest.charFilters())));
    analyzeRequest.explain(request.paramAsBoolean("explain", false));
    analyzeRequest.attributes(request.paramAsStringArray("attributes", analyzeRequest.attributes()));

    if (RestActions.hasBodyContent(request)) {
        XContentType type = RestActions.guessBodyContentType(request);
        if (type == null) {
            if (texts == null || texts.length == 0) {
                texts = new String[]{ RestActions.getRestContent(request).toUtf8() };
                analyzeRequest.text(texts);
            }
        } else {
            // NOTE: if rest request with xcontent body has request parameters, the parameters does not override xcontent values
            buildFromContent(RestActions.getRestContent(request), analyzeRequest, parseFieldMatcher);
        }
    }

    client.admin().indices().analyze(analyzeRequest, new RestToXContentListener<AnalyzeResponse>(channel));
}

开发者ID:baidu，项目名称:Elasticsearch，代码行数:32，代码来源:RestAnalyzeAction.java

示例13: testClientConnection

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
@Test
public void testClientConnection() throws Exception {
    AnalyzeRequest analyzeRequest = new AnalyzeRequest();
    analyzeRequest.text("美女");
    ActionFuture<AnalyzeResponse> analyzeResponseActionFuture = client.admin().indices().analyze(analyzeRequest);
    List<AnalyzeResponse.AnalyzeToken> analyzeTokens =  analyzeResponseActionFuture.actionGet().getTokens();
    for (AnalyzeResponse.AnalyzeToken analyzeToken  : analyzeTokens){
        System.out.println(analyzeToken.getTerm());
    }
}

开发者ID:felayman，项目名称:elasticsearch-full，代码行数:11，代码来源:XPackBaseDemo.java

示例14: testElasticsearchTemplateConnection

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
@Test
public void testElasticsearchTemplateConnection() throws Exception {
    AnalyzeRequest analyzeRequest = new AnalyzeRequest();
    analyzeRequest.text("中华人民共和国");
    ActionFuture<AnalyzeResponse> analyzeResponseActionFuture =  elasticsearchTemplate.getClient().admin().indices().analyze(analyzeRequest);
    List<AnalyzeResponse.AnalyzeToken> analyzeTokens =  analyzeResponseActionFuture.actionGet().getTokens();
    for (AnalyzeResponse.AnalyzeToken analyzeToken  : analyzeTokens){
        System.out.println(analyzeToken.getTerm());
    }
}

开发者ID:felayman，项目名称:elasticsearch-full，代码行数:11，代码来源:XPackBaseDemo.java

示例15: testClientConnection

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
@Test
public void testClientConnection() throws Exception {
    AnalyzeRequest analyzeRequest = new AnalyzeRequest();
    analyzeRequest.text("中华人民共和国");
    ActionFuture<AnalyzeResponse> analyzeResponseActionFuture = client.admin().indices().analyze(analyzeRequest);
    List<AnalyzeResponse.AnalyzeToken> analyzeTokens =  analyzeResponseActionFuture.actionGet().getTokens();
    for (AnalyzeResponse.AnalyzeToken analyzeToken  : analyzeTokens){
        System.out.println(analyzeToken.getTerm());
    }
}

开发者ID:felayman，项目名称:elasticsearch-full，代码行数:11，代码来源:BaseDemo.java

示例16: showAnaylzerText

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
private static void showAnaylzerText(IndicesAdminClient indicesAdminClient,String analyzerName, String text) {
    AnalyzeResponse analyzeResponse = indicesAdminClient.analyze(new AnalyzeRequest(INDEX_NAME).analyzer(analyzerName).text(text)).actionGet();
    List<AnalyzeResponse.AnalyzeToken> token=analyzeResponse.getTokens();
    for (AnalyzeResponse.AnalyzeToken analyzeToken : token) {
        log.info(analyzerName+": {}",analyzeToken.getTerm());
    }

}

开发者ID:ggj2010，项目名称:javabase，代码行数:9，代码来源:CrudDemo.java

示例17: analyze

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
/**
 * 分词-无法分词则返回空集合
 * 
 * @param analyzer
 * @param str
 * @return
 */
public static List<String> analyze(String analyzer, String str) {

    AnalyzeResponse ar = null;
    try {
        AnalyzeRequest request = new AnalyzeRequest(str).analyzer(analyzer).index(
                getCurrentValidIndex());
        ar = ESClient.getClient().admin().indices().analyze(request).actionGet();
    } catch (IndexMissingException e) {
        if (!reLoad) {
            synchronized (AnalyzeHelper.class) {
                if (!reLoad) {
                    reLoad = true;
                }
            }
        }
        return analyze(analyzer, str);
    }

    if (ar == null || ar.getTokens() == null || ar.getTokens().size() < 1) {
        return Lists.newArrayList();
    }
    List<String> analyzeTokens = Lists.newArrayList();
    for (AnalyzeToken at : ar.getTokens()) {
        analyzeTokens.add(at.getTerm());
    }
    return analyzeTokens;
}

开发者ID:hailin0，项目名称:es-service-parent，代码行数:35，代码来源:AnalyzeHelper.java

示例18: assertAnalyzesTo

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
protected void assertAnalyzesTo(String analyzer, String input, String[] output, int startOffsets[], int endOffsets[], String types[], int posIncrements[]) {
    assertThat(output, notNullValue());
    AnalyzeResponse response = node.client().admin().indices().analyze(new AnalyzeRequest(INDEX, input).analyzer(analyzer)).actionGet();
    if (VERBOSE) {
        try {
            Map<String,String> params = new HashMap<String,String>();
            params.put("format", "text");
            logger.info("Tokens for \""+input+"\": " + response.toXContent(jsonBuilder().startObject(), new ToXContent.MapParams(params)).endObject().string());
        } catch (IOException e) {
            logger.error("Tokens for \""+input+"\": ERROR", e);
        }
    }
    Iterator<AnalyzeResponse.AnalyzeToken> tokens = response.iterator();
    int pos = 0;
    for (int i = 0; i < output.length; i++) {
        assertThat("token "+i+" does not exist", tokens.hasNext());
        AnalyzeResponse.AnalyzeToken token = tokens.next();
        assertThat("term "+i, token.getTerm(), equalTo(output[i]));
        if (startOffsets != null)
            assertThat("startOffset "+i, token.getStartOffset(), equalTo(startOffsets[i]));
        if (endOffsets != null)
            assertThat("endOffset "+i, token.getEndOffset(), equalTo(endOffsets[i]));
        if (types != null)
            assertThat("type "+i, token.getType(), equalTo(types[i]));
        if (posIncrements != null) {
            pos += posIncrements[i];
            assertThat("position "+i, token.getPosition(), equalTo(pos));
        }
    }
}

开发者ID:yakaz，项目名称:elasticsearch-analysis-worddelimiter2，代码行数:31，代码来源:BaseESTest.java

示例19: analyze

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
@Override
public ActionFuture<AnalyzeResponse> analyze(final AnalyzeRequest request) {
    return execute(AnalyzeAction.INSTANCE, request);
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:5，代码来源:AbstractClient.java

示例20: buildFromContent

import org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest; //导入依赖的package包/类
static void buildFromContent(XContentParser parser, AnalyzeRequest analyzeRequest)
        throws IOException {
    if (parser.nextToken() != XContentParser.Token.START_OBJECT) {
        throw new IllegalArgumentException("Malformed content, must start with an object");
    } else {
        XContentParser.Token token;
        String currentFieldName = null;
        while ((token = parser.nextToken()) != XContentParser.Token.END_OBJECT) {
            if (token == XContentParser.Token.FIELD_NAME) {
                currentFieldName = parser.currentName();
            } else if (Fields.TEXT.match(currentFieldName) && token == XContentParser.Token.VALUE_STRING) {
                analyzeRequest.text(parser.text());
            } else if (Fields.TEXT.match(currentFieldName) && token == XContentParser.Token.START_ARRAY) {
                List<String> texts = new ArrayList<>();
                while ((token = parser.nextToken()) != XContentParser.Token.END_ARRAY) {
                    if (token.isValue() == false) {
                        throw new IllegalArgumentException(currentFieldName + " array element should only contain text");
                    }
                    texts.add(parser.text());
                }
                analyzeRequest.text(texts.toArray(new String[texts.size()]));
            } else if (Fields.ANALYZER.match(currentFieldName) && token == XContentParser.Token.VALUE_STRING) {
                analyzeRequest.analyzer(parser.text());
            } else if (Fields.FIELD.match(currentFieldName) && token == XContentParser.Token.VALUE_STRING) {
                analyzeRequest.field(parser.text());
            } else if (Fields.TOKENIZER.match(currentFieldName)) {
                if (token == XContentParser.Token.VALUE_STRING) {
                    analyzeRequest.tokenizer(parser.text());
                } else if (token == XContentParser.Token.START_OBJECT) {
                    analyzeRequest.tokenizer(parser.map());
                } else {
                    throw new IllegalArgumentException(currentFieldName + " should be tokenizer's name or setting");
                }
            } else if (Fields.TOKEN_FILTERS.match(currentFieldName)
                    && token == XContentParser.Token.START_ARRAY) {
                while ((token = parser.nextToken()) != XContentParser.Token.END_ARRAY) {
                    if (token == XContentParser.Token.VALUE_STRING) {
                        analyzeRequest.addTokenFilter(parser.text());
                    } else if (token == XContentParser.Token.START_OBJECT) {
                        analyzeRequest.addTokenFilter(parser.map());
                    } else {
                        throw new IllegalArgumentException(currentFieldName
                                + " array element should contain filter's name or setting");
                    }
                }
            } else if (Fields.CHAR_FILTERS.match(currentFieldName)
                    && token == XContentParser.Token.START_ARRAY) {
                while ((token = parser.nextToken()) != XContentParser.Token.END_ARRAY) {
                    if (token == XContentParser.Token.VALUE_STRING) {
                        analyzeRequest.addCharFilter(parser.text());
                    } else if (token == XContentParser.Token.START_OBJECT) {
                        analyzeRequest.addCharFilter(parser.map());
                    } else {
                        throw new IllegalArgumentException(currentFieldName
                                + " array element should contain char filter's name or setting");
                    }
                }
            } else if (Fields.EXPLAIN.match(currentFieldName)) {
                if (parser.isBooleanValue()) {
                    analyzeRequest.explain(parser.booleanValue());
                } else {
                    throw new IllegalArgumentException(currentFieldName + " must be either 'true' or 'false'");
                }
            } else if (Fields.ATTRIBUTES.match(currentFieldName) && token == XContentParser.Token.START_ARRAY) {
                List<String> attributes = new ArrayList<>();
                while ((token = parser.nextToken()) != XContentParser.Token.END_ARRAY) {
                    if (token.isValue() == false) {
                        throw new IllegalArgumentException(currentFieldName + " array element should only contain attribute name");
                    }
                    attributes.add(parser.text());
                }
                analyzeRequest.attributes(attributes.toArray(new String[attributes.size()]));
            } else {
                throw new IllegalArgumentException("Unknown parameter ["
                        + currentFieldName + "] in request body or parameter is of the wrong type[" + token + "] ");
            }
        }
    }
}

开发者ID:justor，项目名称:elasticsearch_my，代码行数:80，代码来源:RestAnalyzeAction.java

注：本文中的org.elasticsearch.action.admin.indices.analyze.AnalyzeRequest类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java Property类代码示例发布时间：2022-05-23

Java RouterDescriptor类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18003|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9584|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8134|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8518|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8422|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9321|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8385|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7818|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8373|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7368|2022-11-06

客服电话

电子邮件

Java AnalyzeRequest类代码示例

示例1: testParseXContentForAnalyzeRequest

示例2: testTokenizer

示例3: prepareRequest

示例4: testParseXContentForAnalyzeRequestWithCustomFilters

示例5: testParseXContentForAnalyzeRequestWithUnknownParamThrowsException

示例6: testParseXContentForAnalyzeRequestWithInvalidStringExplainParamThrowsException

示例7: testNoIndexAnalyzers

示例8: testFillsAttributes

示例9: testGetIndexAnalyserWithoutIndexAnalyzers

示例10: testNonPreBuildTokenFilter

示例11: testAnalyze

示例12: handleRequest

示例13: testClientConnection

示例14: testElasticsearchTemplateConnection

示例15: testClientConnection

示例16: showAnaylzerText

示例17: analyze

示例18: assertAnalyzesTo

示例19: analyze

示例20: buildFromContent

请发表评论

全部评论

上一篇：

下一篇：

librespeed/speedtest: Self-hosted Speedt

avehtari/BDA_m_demos: Bayesian Data Anal

四维彩超怎么看性别？四维看男孩女孩诀窍

CVE-2022-24659

medfreeman/markdown-it-toc-and-anchor: m

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053