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, boolean allowExplicitIndex, 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, boolean allowExplicitIndex, 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.
-
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, boolean allowExplicitIndex, 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, boolean allowExplicitIndex, 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
-