org.elasticsearch.common.xcontent.XContentBuilder.getOutputStream()方法的使用及代码示例

x33g5p2x  于2022-02-02 转载在 其他  
字(2.4k)|赞(0)|评价(0)|浏览(101)

本文整理了Java中org.elasticsearch.common.xcontent.XContentBuilder.getOutputStream()方法的一些代码示例,展示了XContentBuilder.getOutputStream()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XContentBuilder.getOutputStream()方法的具体详情如下:
包路径:org.elasticsearch.common.xcontent.XContentBuilder
类名称:XContentBuilder
方法名:getOutputStream

XContentBuilder.getOutputStream介绍

暂无

代码示例

代码示例来源:origin: org.elasticsearch/elasticsearch

/**
 * Convert an {@link XContentBuilder} into a BytesReference. This method closes the builder,
 * so no further fields may be added.
 */
public static BytesReference bytes(XContentBuilder xContentBuilder) {
  xContentBuilder.close();
  OutputStream stream = xContentBuilder.getOutputStream();
  if (stream instanceof ByteArrayOutputStream) {
    return new BytesArray(((ByteArrayOutputStream) stream).toByteArray());
  } else {
    return ((BytesStream) stream).bytes();
  }
}

代码示例来源:origin: apache/servicemix-bundles

/**
 * Convert an {@link XContentBuilder} into a BytesReference. This method closes the builder,
 * so no further fields may be added.
 */
public static BytesReference bytes(XContentBuilder xContentBuilder) {
  xContentBuilder.close();
  OutputStream stream = xContentBuilder.getOutputStream();
  if (stream instanceof ByteArrayOutputStream) {
    return new BytesArray(((ByteArrayOutputStream) stream).toByteArray());
  } else {
    return ((BytesStream) stream).bytes();
  }
}

代码示例来源:origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

/**
 * Convert an {@link XContentBuilder} into a BytesReference. This method closes the builder,
 * so no further fields may be added.
 */
public static BytesReference bytes(XContentBuilder xContentBuilder) {
  xContentBuilder.close();
  OutputStream stream = xContentBuilder.getOutputStream();
  if (stream instanceof ByteArrayOutputStream) {
    return new BytesArray(((ByteArrayOutputStream) stream).toByteArray());
  } else {
    return ((BytesStream) stream).bytes();
  }
}

代码示例来源:origin: org.nuxeo.elasticsearch/nuxeo-elasticsearch-core

private static GeoPoint parseGeoPointString(String value) {
  try {
    XContentBuilder content = JsonXContent.contentBuilder();
    content.value(value);
    content.flush();
    content.close();
    try (XContentParser parser = JsonXContent.jsonXContent.createParser(NamedXContentRegistry.EMPTY,
        THROW_UNSUPPORTED_OPERATION, ((ByteArrayOutputStream) content.getOutputStream()).toByteArray())) {
      parser.nextToken();
      return GeoUtils.parseGeoPoint(parser);
    }
  } catch (IOException e) {
    throw new IllegalArgumentException("Invalid value for geopoint: " + e.getMessage());
  }
}

相关文章

微信公众号

最新文章

更多