Class BulkRequestParser

java.lang.Object
org.elasticsearch.action.bulk.BulkRequestParser

public final class BulkRequestParser
extends java.lang.Object
Helper to parse bulk requests. This should be considered an internal class.
  • Constructor Summary

    Constructors
    Constructor Description
    BulkRequestParser​(boolean warnOnTypeUsage)
    Create a new parser.
  • Method Summary

    Modifier and Type Method Description
    void parse​(BytesReference data, java.lang.String defaultIndex, java.lang.String defaultType, java.lang.String defaultRouting, FetchSourceContext defaultFetchSourceContext, java.lang.String defaultPipeline, java.lang.Boolean defaultRequireAlias, boolean allowExplicitIndex, org.elasticsearch.common.xcontent.XContentType xContentType, java.util.function.Consumer<IndexRequest> indexRequestConsumer, java.util.function.Consumer<UpdateRequest> updateRequestConsumer, java.util.function.Consumer<DeleteRequest> deleteRequestConsumer)
    void parse​(BytesReference data, java.lang.String defaultIndex, java.lang.String defaultRouting, FetchSourceContext defaultFetchSourceContext, java.lang.String defaultPipeline, java.lang.Boolean defaultRequireAlias, boolean allowExplicitIndex, org.elasticsearch.common.xcontent.XContentType xContentType, java.util.function.Consumer<IndexRequest> indexRequestConsumer, java.util.function.Consumer<UpdateRequest> updateRequestConsumer, java.util.function.Consumer<DeleteRequest> deleteRequestConsumer)
    Parse the provided data assuming the provided default values.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • Constructor Details

    • BulkRequestParser

      public BulkRequestParser​(boolean warnOnTypeUsage)
      Create a new parser.
      Parameters:
      warnOnTypeUsage - whether it warns upon types being explicitly specified
  • Method Details

    • parse

      public void parse​(BytesReference data, @Nullable java.lang.String defaultIndex, @Nullable java.lang.String defaultRouting, @Nullable FetchSourceContext defaultFetchSourceContext, @Nullable java.lang.String defaultPipeline, @Nullable java.lang.Boolean defaultRequireAlias, boolean allowExplicitIndex, org.elasticsearch.common.xcontent.XContentType xContentType, java.util.function.Consumer<IndexRequest> indexRequestConsumer, java.util.function.Consumer<UpdateRequest> updateRequestConsumer, java.util.function.Consumer<DeleteRequest> deleteRequestConsumer) throws java.io.IOException
      Parse the provided data assuming the provided default values. Index requests will be passed to the indexRequestConsumer, update requests to the updateRequestConsumer and delete requests to the deleteRequestConsumer.
      Throws:
      java.io.IOException
    • parse

      @Deprecated public void parse​(BytesReference data, @Nullable java.lang.String defaultIndex, @Nullable java.lang.String defaultType, @Nullable java.lang.String defaultRouting, @Nullable FetchSourceContext defaultFetchSourceContext, @Nullable java.lang.String defaultPipeline, @Nullable java.lang.Boolean defaultRequireAlias, boolean allowExplicitIndex, org.elasticsearch.common.xcontent.XContentType xContentType, java.util.function.Consumer<IndexRequest> indexRequestConsumer, java.util.function.Consumer<UpdateRequest> updateRequestConsumer, java.util.function.Consumer<DeleteRequest> deleteRequestConsumer) throws java.io.IOException
      Parse the provided data assuming the provided default values. Index requests will be passed to the indexRequestConsumer, update requests to the updateRequestConsumer and delete requests to the deleteRequestConsumer.
      Throws:
      java.io.IOException