Package org.elasticsearch.action.bulk
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)
Deprecated.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 provideddata
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.IOExceptionParse the provideddata
assuming the provided default values. Index requests will be passed to theindexRequestConsumer
, update requests to theupdateRequestConsumer
and delete requests to thedeleteRequestConsumer
.- 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.IOExceptionDeprecated.Parse the provideddata
assuming the provided default values. Index requests will be passed to theindexRequestConsumer
, update requests to theupdateRequestConsumer
and delete requests to thedeleteRequestConsumer
.- Throws:
java.io.IOException
-
parse(BytesReference, String, String, FetchSourceContext, String, Boolean, boolean, XContentType, Consumer, Consumer, Consumer)
instead.