本文整理了Java中org.elasticsearch.common.xcontent.yaml.YamlXContent
类的一些代码示例,展示了YamlXContent
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。YamlXContent
类的具体详情如下:
包路径:org.elasticsearch.common.xcontent.yaml.YamlXContent
类名称:YamlXContent
[英]A YAML based content implementation using Jackson.
[中]使用Jackson的基于YAML的内容实现。
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
@Override
public XContentParser createParser(NamedXContentRegistry xContentRegistry, BytesReference bytes) throws IOException {
return createParser(xContentRegistry, bytes.streamInput());
}
代码示例来源:origin: com.strapdata.elasticsearch/elasticsearch
/**
* Returns a binary content builder for the provided content type.
*/
public static XContentBuilder contentBuilder(XContentType type) throws IOException {
if (type == XContentType.JSON) {
return JsonXContent.contentBuilder();
} else if (type == XContentType.SMILE) {
return SmileXContent.contentBuilder();
} else if (type == XContentType.YAML) {
return YamlXContent.contentBuilder();
} else if (type == XContentType.CBOR) {
return CborXContent.contentBuilder();
}
throw new IllegalArgumentException("No matching content type for " + type);
}
代码示例来源:origin: org.elasticsearch/elasticsearch-x-content
/**
* Returns a binary content builder for the provided content type.
*/
public static XContentBuilder contentBuilder(XContentType type) throws IOException {
if (type == XContentType.JSON) {
return JsonXContent.contentBuilder();
} else if (type == XContentType.SMILE) {
return SmileXContent.contentBuilder();
} else if (type == XContentType.YAML) {
return YamlXContent.contentBuilder();
} else if (type == XContentType.CBOR) {
return CborXContent.contentBuilder();
}
throw new IllegalArgumentException("No matching content type for " + type);
}
代码示例来源:origin: apache/servicemix-bundles
/**
* Returns a binary content builder for the provided content type.
*/
public static XContentBuilder contentBuilder(XContentType type) throws IOException {
if (type == XContentType.JSON) {
return JsonXContent.contentBuilder();
} else if (type == XContentType.SMILE) {
return SmileXContent.contentBuilder();
} else if (type == XContentType.YAML) {
return YamlXContent.contentBuilder();
} else if (type == XContentType.CBOR) {
return CborXContent.contentBuilder();
}
throw new IllegalArgumentException("No matching content type for " + type);
}
代码示例来源:origin: com.strapdata.elasticsearch.test/framework
public static ClientYamlTestSuite parse(String api, Path file) throws IOException {
if (!Files.isRegularFile(file)) {
throw new IllegalArgumentException(file.toAbsolutePath() + " is not a file");
}
String filename = file.getFileName().toString();
//remove the file extension
int i = filename.lastIndexOf('.');
if (i > 0) {
filename = filename.substring(0, i);
}
//our yaml parser seems to be too tolerant. Each yaml suite must end with \n, otherwise clients tests might break.
try (FileChannel channel = FileChannel.open(file, StandardOpenOption.READ)) {
ByteBuffer bb = ByteBuffer.wrap(new byte[1]);
if (channel.size() == 0) {
throw new IllegalArgumentException("test suite file " + file.toString() + " is empty");
}
channel.read(bb, channel.size() - 1);
if (bb.get(0) != 10) {
throw new IOException("test suite [" + api + "/" + filename + "] doesn't end with line feed (\\n)");
}
}
try (XContentParser parser = YamlXContent.yamlXContent.createParser(ExecutableSection.XCONTENT_REGISTRY,
Files.newInputStream(file))) {
return parse(api, filename, parser);
} catch(Exception e) {
throw new IOException("Error parsing " + api + "/" + filename, e);
}
}
代码示例来源:origin: harbby/presto-connectors
/**
* Returns a binary content builder for the provided content type.
*/
public static XContentBuilder contentBuilder(XContentType type) throws IOException {
if (type == XContentType.JSON) {
return JsonXContent.contentBuilder();
} else if (type == XContentType.SMILE) {
return SmileXContent.contentBuilder();
} else if (type == XContentType.YAML) {
return YamlXContent.contentBuilder();
} else if (type == XContentType.CBOR) {
return CborXContent.contentBuilder();
}
throw new IllegalArgumentException("No matching content type for " + type);
}
代码示例来源:origin: harbby/presto-connectors
@Override
public XContentParser createParser(BytesReference bytes) throws IOException {
if (bytes.hasArray()) {
return createParser(bytes.array(), bytes.arrayOffset(), bytes.length());
}
return createParser(bytes.streamInput());
}
内容来源于网络,如有侵权,请联系作者删除!