Package org.elasticsearch.action.bulk

Class BulkRequestParser

java.lang.Object

org.elasticsearch.action.bulk.BulkRequestParser

public final class BulkRequestParser
extends 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, String defaultIndex, String defaultType, String defaultRouting, FetchSourceContext defaultFetchSourceContext, String defaultPipeline, Boolean defaultRequireAlias, boolean allowExplicitIndex, XContentType xContentType, Consumer<IndexRequest> indexRequestConsumer, Consumer<UpdateRequest> updateRequestConsumer, Consumer<DeleteRequest> deleteRequestConsumer)	Deprecated. Use parse(BytesReference, String, String, FetchSourceContext, String, Boolean, boolean, XContentType, Consumer, Consumer, Consumer) instead.
void	parse(BytesReference data, String defaultIndex, String defaultRouting, FetchSourceContext defaultFetchSourceContext, String defaultPipeline, Boolean defaultRequireAlias, boolean allowExplicitIndex, XContentType xContentType, Consumer<IndexRequest> indexRequestConsumer, Consumer<UpdateRequest> updateRequestConsumer, 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
 String defaultIndex,
 @Nullable
 String defaultRouting,
 @Nullable
 FetchSourceContext defaultFetchSourceContext,
 @Nullable
 String defaultPipeline,
 @Nullable
 Boolean defaultRequireAlias,
 boolean allowExplicitIndex,
 XContentType xContentType,
 Consumer<IndexRequest> indexRequestConsumer,
 Consumer<UpdateRequest> updateRequestConsumer,
 Consumer<DeleteRequest> deleteRequestConsumer)
           throws 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:

IOException

parse

@Deprecated
public void parse(BytesReference data,
 @Nullable
 String defaultIndex,
 @Nullable
 String defaultType,
 @Nullable
 String defaultRouting,
 @Nullable
 FetchSourceContext defaultFetchSourceContext,
 @Nullable
 String defaultPipeline,
 @Nullable
 Boolean defaultRequireAlias,
 boolean allowExplicitIndex,
 XContentType xContentType,
 Consumer<IndexRequest> indexRequestConsumer,
 Consumer<UpdateRequest> updateRequestConsumer,
 Consumer<DeleteRequest> deleteRequestConsumer)
           throws IOException

Deprecated.

Use parse(BytesReference, String, String, FetchSourceContext, String, Boolean, boolean, XContentType, Consumer, Consumer, Consumer) instead.

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:

IOException