org.elasticsearch.action.index

Class IndexRequest

java.lang.Object

org.elasticsearch.transport.TransportMessage

org.elasticsearch.transport.TransportRequest

org.elasticsearch.action.ActionRequest

org.elasticsearch.action.support.replication.ReplicationRequest<R>

org.elasticsearch.action.support.replication.ReplicatedWriteRequest<IndexRequest>

org.elasticsearch.action.index.IndexRequest

All Implemented Interfaces:

CompositeIndicesRequest, DocWriteRequest<IndexRequest>, IndicesRequest, WriteRequest<IndexRequest>, Streamable, TaskAwareRequest

public class IndexRequest
extends ReplicatedWriteRequest<IndexRequest>
implements DocWriteRequest<IndexRequest>, CompositeIndicesRequest

Index request to index a typed JSON document into a specific index and make it searchable. Best created using Requests.indexRequest(String). The index requires the ReplicationRequest.index(), type(String), id(String) and source(byte[], XContentType) to be set. The source (content to index) can be set in its bytes form using (source(byte[], XContentType)), its string form (source(String, XContentType)) or using a XContentBuilder (source(org.elasticsearch.common.xcontent.XContentBuilder)). If the id(String) is not set, it will be automatically generated.

See Also:

IndexResponse, Requests.indexRequest(String), Client.index(IndexRequest)

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.transport.TransportRequest

TransportRequest.Empty

Nested classes/interfaces inherited from interface org.elasticsearch.action.DocWriteRequest

DocWriteRequest.OpType

Nested classes/interfaces inherited from interface org.elasticsearch.action.IndicesRequest

IndicesRequest.Replaceable

Nested classes/interfaces inherited from interface org.elasticsearch.action.support.WriteRequest

WriteRequest.RefreshPolicy

Field Summary

Fields

Modifier and Type	Field and Description
static int	UNSET_AUTO_GENERATED_TIMESTAMP Value for getAutoGeneratedTimestamp() if the document has an external provided ID.

Fields inherited from class org.elasticsearch.action.support.replication.ReplicationRequest

DEFAULT_TIMEOUT, index, shardId, timeout, waitForActiveShards

Constructor Summary

Constructors

Constructor and Description
IndexRequest()
IndexRequest(java.lang.String index) Constructs a new index request against the specific index.
IndexRequest(java.lang.String index, java.lang.String type) Constructs a new index request against the specific index and type.
IndexRequest(java.lang.String index, java.lang.String type, java.lang.String id) Constructs a new index request against the index, type, id and using the source.

Method Summary

Modifier and Type	Method and Description
IndexRequest	create(boolean create) Set to true to force this index to use OpType#CREATE.
long	getAutoGeneratedTimestamp() Returns the timestamp the auto generated ID was created or -1 if the document has no auto generated timestamp.
XContentType	getContentType() The content type.
java.lang.String	getPipeline() Returns the ingest pipeline to be executed before indexing the document
java.lang.String	id() The id of the indexed document.
IndexRequest	id(java.lang.String id) Sets the id of the indexed document.
boolean	isRetry() Returns true if this request has been sent to a shard copy more than once.
void	onRetry() This method is called before this replication request is retried the first time.
DocWriteRequest.OpType	opType() Get the requested document operation type of the request
IndexRequest	opType(DocWriteRequest.OpType opType) Sets the type of operation to perform.
IndexRequest	opType(java.lang.String opType) Sets a string representation of the #opType(OpType).
java.lang.String	parent() Get the parent for this request
IndexRequest	parent(java.lang.String parent) Sets the parent id of this document.
void	process(MappingMetaData mappingMd, boolean allowIdGeneration, java.lang.String concreteIndex)
void	readFrom(StreamInput in) Set this object's fields from a StreamInput.
void	resolveRouting(MetaData metaData)
java.lang.String	routing() Controls the shard routing of the request.
IndexRequest	routing(java.lang.String routing) Controls the shard routing of the request.
IndexRequest	setPipeline(java.lang.String pipeline) Sets the ingest pipeline to be executed before indexing the document
BytesReference	source() The source of the document to index, recopied to a new array if it is unsafe.
IndexRequest	source(byte[] source) Deprecated. use source(byte[], XContentType)
IndexRequest	source(byte[] source, int offset, int length) Deprecated. use source(byte[], int, int, XContentType)
IndexRequest	source(byte[] source, int offset, int length, XContentType xContentType) Sets the document to index in bytes form (assumed to be safe to be used from different threads).
IndexRequest	source(byte[] source, XContentType xContentType) Sets the document to index in bytes form.
IndexRequest	source(BytesReference source) Deprecated. use source(BytesReference, XContentType)
IndexRequest	source(BytesReference source, XContentType xContentType) Sets the document to index in bytes form.
IndexRequest	source(java.util.Map source) Index the Map in Requests.INDEX_CONTENT_TYPE format
IndexRequest	source(java.util.Map source, XContentType contentType) Index the Map as the provided content type.
IndexRequest	source(java.lang.Object... source) Sets the content source to index using the default content type (Requests.INDEX_CONTENT_TYPE)
IndexRequest	source(java.lang.String source) Deprecated. use source(String, XContentType)
IndexRequest	source(java.lang.String source, XContentType xContentType) Sets the document source to index.
IndexRequest	source(XContentBuilder sourceBuilder) Sets the content source to index.
IndexRequest	source(XContentType xContentType, java.lang.Object... source) Sets the content source to index.
java.util.Map<java.lang.String,java.lang.Object>	sourceAsMap()
java.lang.String	timestamp() Deprecated.
IndexRequest	timestamp(java.lang.String timestamp) Deprecated.
java.lang.String	toString()
TimeValue	ttl() Deprecated.
IndexRequest	ttl(long ttl) Deprecated.
IndexRequest	ttl(java.lang.String ttl) Deprecated.
IndexRequest	ttl(TimeValue ttl) Deprecated.
java.lang.String	type() The type of the indexed document.
IndexRequest	type(java.lang.String type) Sets the type of the indexed document.
ActionRequestValidationException	validate()
long	version() Returns stored version.
IndexRequest	version(long version) Sets the version, which will perform the operation only if a matching version exists and no changes happened on the doc since then.
VersionType	versionType() Get the document version type for this request
IndexRequest	versionType(VersionType versionType) Sets the versioning type.
void	writeTo(StreamOutput out) Write this object's fields to a StreamOutput.

Methods inherited from class org.elasticsearch.action.support.replication.ReplicatedWriteRequest

getRefreshPolicy, setRefreshPolicy

Methods inherited from class org.elasticsearch.action.support.replication.ReplicationRequest

createTask, getDescription, index, index, indices, indicesOptions, primaryTerm, primaryTerm, setShardId, shardId, timeout, timeout, timeout, waitForActiveShards, waitForActiveShards, waitForActiveShards

Methods inherited from class org.elasticsearch.action.ActionRequest

getShouldStoreResult

Methods inherited from class org.elasticsearch.transport.TransportRequest

getParentTask, setParentTask

Methods inherited from class org.elasticsearch.transport.TransportMessage

remoteAddress, remoteAddress

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.elasticsearch.action.DocWriteRequest

index, indicesOptions, readDocumentRequest, writeDocumentRequest

Methods inherited from interface org.elasticsearch.action.IndicesRequest

indices

Methods inherited from interface org.elasticsearch.action.support.WriteRequest

setRefreshPolicy

Methods inherited from interface org.elasticsearch.tasks.TaskAwareRequest

setParentTask

Field Detail

UNSET_AUTO_GENERATED_TIMESTAMP

public static final int UNSET_AUTO_GENERATED_TIMESTAMP

Value for getAutoGeneratedTimestamp() if the document has an external provided ID.

See Also:

Constant Field Values

Constructor Detail

IndexRequest

public IndexRequest()

IndexRequest

public IndexRequest(java.lang.String index)

Constructs a new index request against the specific index. The type(String) source(byte[], XContentType) must be set.

IndexRequest

public IndexRequest(java.lang.String index,
                    java.lang.String type)

Constructs a new index request against the specific index and type. The source(byte[]) must be set.

IndexRequest

public IndexRequest(java.lang.String index,
                    java.lang.String type,
                    java.lang.String id)

Constructs a new index request against the index, type, id and using the source.

Parameters:

index - The index to index into

type - The type to index into

id - The id of document

Method Detail

validate

public ActionRequestValidationException validate()

Specified by:

validate in interface WriteRequest<IndexRequest>

Overrides:

validate in class ReplicationRequest<IndexRequest>

getContentType

public XContentType getContentType()

The content type. This will be used when generating a document from user provided objects like Maps and when parsing the source at index time

type

public java.lang.String type()

The type of the indexed document.

Specified by:

type in interface DocWriteRequest<IndexRequest>

Returns:

the type

type

public IndexRequest type(java.lang.String type)

Sets the type of the indexed document.

id

public java.lang.String id()

The id of the indexed document. If not set, will be automatically generated.

Specified by:

id in interface DocWriteRequest<IndexRequest>

Returns:

the id

id

public IndexRequest id(java.lang.String id)

Sets the id of the indexed document. If not set, will be automatically generated.

routing

public IndexRequest routing(java.lang.String routing)

Controls the shard routing of the request. Using this value to hash the shard and not the id.

Specified by:

routing in interface DocWriteRequest<IndexRequest>

Returns:

the Request

routing

public java.lang.String routing()

Controls the shard routing of the request. Using this value to hash the shard and not the id.

Specified by:

routing in interface DocWriteRequest<IndexRequest>

Returns:

the Routing

parent

public IndexRequest parent(java.lang.String parent)

Sets the parent id of this document.

parent

public java.lang.String parent()

Description copied from interface: DocWriteRequest

Get the parent for this request

Specified by:

parent in interface DocWriteRequest<IndexRequest>

Returns:

the Parent

timestamp

@Deprecated
public IndexRequest timestamp(java.lang.String timestamp)

Deprecated.

Sets the timestamp either as millis since the epoch, or, in the configured date format.

timestamp

@Deprecated
public java.lang.String timestamp()

Deprecated.

ttl

@Deprecated
public IndexRequest ttl(java.lang.String ttl)

Deprecated.

Sets the ttl value as a time value expression.

ttl

@Deprecated
public IndexRequest ttl(TimeValue ttl)

Deprecated.

Sets the ttl as a TimeValue instance.

ttl

@Deprecated
public IndexRequest ttl(long ttl)

Deprecated.

Sets the relative ttl value in milliseconds. It musts be greater than 0 as it makes little sense otherwise.

ttl

@Deprecated
public TimeValue ttl()

Deprecated.

Returns the ttl as a TimeValue

setPipeline

public IndexRequest setPipeline(java.lang.String pipeline)

Sets the ingest pipeline to be executed before indexing the document

getPipeline

public java.lang.String getPipeline()

Returns the ingest pipeline to be executed before indexing the document

source

public BytesReference source()

The source of the document to index, recopied to a new array if it is unsafe.

sourceAsMap

public java.util.Map<java.lang.String,java.lang.Object> sourceAsMap()

source

public IndexRequest source(java.util.Map source)
                    throws ElasticsearchGenerationException

Index the Map in Requests.INDEX_CONTENT_TYPE format

Parameters:

source - The map to index

Throws:

ElasticsearchGenerationException

source

public IndexRequest source(java.util.Map source,
                           XContentType contentType)
                    throws ElasticsearchGenerationException

Index the Map as the provided content type.

Parameters:

source - The map to index

Throws:

ElasticsearchGenerationException

source

@Deprecated
public IndexRequest source(java.lang.String source)

Deprecated. use source(String, XContentType)

Sets the document source to index.

source

public IndexRequest source(java.lang.String source,
                           XContentType xContentType)

Sets the document source to index. Note, its preferable to either set it using source(org.elasticsearch.common.xcontent.XContentBuilder) or using the source(byte[], XContentType).

source

public IndexRequest source(XContentBuilder sourceBuilder)

Sets the content source to index.

source

public IndexRequest source(java.lang.Object... source)

Sets the content source to index using the default content type (Requests.INDEX_CONTENT_TYPE)

Note: the number of objects passed to this method must be an even number. Also the first argument in each pair (the field name) must have a valid String representation.

source

public IndexRequest source(XContentType xContentType,
                           java.lang.Object... source)

Sets the content source to index.

Note: the number of objects passed to this method as varargs must be an even number. Also the first argument in each pair (the field name) must have a valid String representation.

source

@Deprecated
public IndexRequest source(BytesReference source)

Deprecated. use source(BytesReference, XContentType)

Sets the document to index in bytes form.

source

public IndexRequest source(BytesReference source,
                           XContentType xContentType)

Sets the document to index in bytes form.

source

@Deprecated
public IndexRequest source(byte[] source)

Deprecated. use source(byte[], XContentType)

Sets the document to index in bytes form.

source

public IndexRequest source(byte[] source,
                           XContentType xContentType)

Sets the document to index in bytes form.

source

@Deprecated
public IndexRequest source(byte[] source,
                                       int offset,
                                       int length)

Deprecated. use source(byte[], int, int, XContentType)

Sets the document to index in bytes form (assumed to be safe to be used from different threads).

Parameters:

source - The source to index

offset - The offset in the byte array

length - The length of the data

source

public IndexRequest source(byte[] source,
                           int offset,
                           int length,
                           XContentType xContentType)

Sets the document to index in bytes form (assumed to be safe to be used from different threads).

Parameters:

source - The source to index

offset - The offset in the byte array

length - The length of the data

opType

public IndexRequest opType(DocWriteRequest.OpType opType)

Sets the type of operation to perform.

opType

public IndexRequest opType(java.lang.String opType)

Sets a string representation of the #opType(OpType). Can be either "index" or "create".

create

public IndexRequest create(boolean create)

Set to true to force this index to use OpType#CREATE.

opType

public DocWriteRequest.OpType opType()

Description copied from interface: DocWriteRequest

Get the requested document operation type of the request

Specified by:

opType in interface DocWriteRequest<IndexRequest>

Returns:

the operation type DocWriteRequest.OpType

version

public IndexRequest version(long version)

Description copied from interface: DocWriteRequest

Sets the version, which will perform the operation only if a matching version exists and no changes happened on the doc since then.

Specified by:

version in interface DocWriteRequest<IndexRequest>

version

public long version()

Returns stored version. If currently stored version is Versions.MATCH_ANY and opType is OpType#CREATE, returns Versions.MATCH_DELETED.

Specified by:

version in interface DocWriteRequest<IndexRequest>

Returns:

the document version

versionType

public IndexRequest versionType(VersionType versionType)

Description copied from interface: DocWriteRequest

Sets the versioning type. Defaults to VersionType.INTERNAL.

Specified by:

versionType in interface DocWriteRequest<IndexRequest>

versionType

public VersionType versionType()

Description copied from interface: DocWriteRequest

Get the document version type for this request

Specified by:

versionType in interface DocWriteRequest<IndexRequest>

Returns:

the document version type

process

public void process(@Nullable
                    MappingMetaData mappingMd,
                    boolean allowIdGeneration,
                    java.lang.String concreteIndex)

resolveRouting

public void resolveRouting(MetaData metaData)

readFrom

public void readFrom(StreamInput in)
              throws java.io.IOException

Description copied from interface: Streamable

Set this object's fields from a StreamInput.

Specified by:

readFrom in interface Streamable

Overrides:

readFrom in class ReplicatedWriteRequest<IndexRequest>

Throws:

java.io.IOException

writeTo

public void writeTo(StreamOutput out)
             throws java.io.IOException

Description copied from interface: Streamable

Write this object's fields to a StreamOutput.

Specified by:

writeTo in interface Streamable

Overrides:

writeTo in class ReplicatedWriteRequest<IndexRequest>

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class ReplicationRequest<IndexRequest>

isRetry

public boolean isRetry()

Returns true if this request has been sent to a shard copy more than once.

onRetry

public void onRetry()

Description copied from class: ReplicationRequest

This method is called before this replication request is retried the first time.

Overrides:

onRetry in class ReplicationRequest<IndexRequest>

getAutoGeneratedTimestamp

public long getAutoGeneratedTimestamp()

Returns the timestamp the auto generated ID was created or -1 if the document has no auto generated timestamp. This method will return a positive value iff the id was auto generated.