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.
-
-
-
Method Detail
-
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.IOException
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
@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.IOException
Deprecated.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
-
-