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

BulkRequest.sliceTrimmingCarriageReturn介绍

[英]Returns the sliced BytesReference. If the XContentType is JSON, the byte preceding the marker is checked to see if it is a carriage return and if so, the BytesReference is sliced so that the carriage return is ignored
[中]返回切片的BytesReference。如果XContentType是JSON，则检查标记前面的字节是否为回车符，如果是回车符，则对BytesReference进行切片，以便忽略回车符

代码示例

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

internalAdd(new IndexRequest(index, type, id).routing(routing).parent(parent).version(version)
        .versionType(versionType).setPipeline(pipeline).setIfSeqNo(ifSeqNo).setIfPrimaryTerm(ifPrimaryTerm)
        .source(sliceTrimmingCarriageReturn(data, from, nextMarker,xContentType), xContentType), payload);
  } else {
    internalAdd(new IndexRequest(index, type, id).routing(routing).parent(parent).version(version)
        .versionType(versionType).create("create".equals(opType)).setPipeline(pipeline)
        .setIfSeqNo(ifSeqNo).setIfPrimaryTerm(ifPrimaryTerm)
        .source(sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType), xContentType), payload);
      .versionType(versionType).create(true).setPipeline(pipeline)
      .setIfSeqNo(ifSeqNo).setIfPrimaryTerm(ifPrimaryTerm)
      .source(sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType), xContentType), payload);
} else if ("update".equals(action)) {
  UpdateRequest updateRequest = new UpdateRequest(index, type, id).routing(routing).parent(parent)
      .parent(parent);
  try (InputStream dataStream = sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType).streamInput();
     XContentParser sliceParser = xContent.createParser(NamedXContentRegistry.EMPTY,
       LoggingDeprecationHandler.INSTANCE, dataStream)) {

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

internalAdd(new IndexRequest(index, type, id).routing(routing).parent(parent).timestamp(timestamp).ttl(ttl).version(version).versionType(versionType)
        .setPipeline(pipeline)
        .source(sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType), xContentType), payload);
  } else {
    internalAdd(new IndexRequest(index, type, id).routing(routing).parent(parent).timestamp(timestamp).ttl(ttl).version(version).versionType(versionType)
        .create("create".equals(opType)).setPipeline(pipeline)
        .source(sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType), xContentType), payload);
      .source(sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType), xContentType), payload);
} else if ("update".equals(action)) {
  UpdateRequest updateRequest = new UpdateRequest(index, type, id).routing(routing).parent(parent).retryOnConflict(retryOnConflict)
                  sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType))) {
    updateRequest.fromXContent(sliceParser);

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

internalAdd(new IndexRequest(index, type, id).routing(routing).parent(parent).version(version).versionType(versionType)
        .setPipeline(pipeline)
        .source(sliceTrimmingCarriageReturn(data, from, nextMarker,xContentType), xContentType), payload);
  } else {
    internalAdd(new IndexRequest(index, type, id).routing(routing).parent(parent).version(version).versionType(versionType)
        .create("create".equals(opType)).setPipeline(pipeline)
        .source(sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType), xContentType), payload);
      .source(sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType), xContentType), payload);
} else if ("update".equals(action)) {
  UpdateRequest updateRequest = new UpdateRequest(index, type, id).routing(routing).parent(parent).retryOnConflict(retryOnConflict)
      .parent(parent);
  try (InputStream dataStream = sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType).streamInput();
     XContentParser sliceParser = xContent.createParser(NamedXContentRegistry.EMPTY,
       LoggingDeprecationHandler.INSTANCE, dataStream)) {

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

internalAdd(new IndexRequest(index, type, id).routing(routing).parent(parent).version(version).versionType(versionType)
        .setPipeline(pipeline)
        .source(sliceTrimmingCarriageReturn(data, from, nextMarker,xContentType), xContentType), payload);
  } else {
    internalAdd(new IndexRequest(index, type, id).routing(routing).parent(parent).version(version).versionType(versionType)
        .create("create".equals(opType)).setPipeline(pipeline)
        .source(sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType), xContentType), payload);
      .source(sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType), xContentType), payload);
} else if ("update".equals(action)) {
  UpdateRequest updateRequest = new UpdateRequest(index, type, id).routing(routing).parent(parent).retryOnConflict(retryOnConflict)
      .parent(parent);
  try (InputStream dataStream = sliceTrimmingCarriageReturn(data, from, nextMarker, xContentType).streamInput();
     XContentParser sliceParser = xContent.createParser(NamedXContentRegistry.EMPTY,
       LoggingDeprecationHandler.INSTANCE, dataStream)) {