Class CreateIfAbsentBulkRequestItem

java.lang.Object

com.flowable.indexing.job.impl.FullDocBulkRequestItem

com.flowable.indexing.job.impl.CreateIfAbsentBulkRequestItem

All Implemented Interfaces:

BulkRequestItem

public class CreateIfAbsentBulkRequestItem
extends FullDocBulkRequestItem

Bulk request item using the Elasticsearch create action: the document is written only if no document with the same _id already exists (otherwise ES returns 409 and leaves the existing one untouched). Used for reindex backfill so it can never clobber a fresher live dual-write in the new index.

Field Summary

Fields

Modifier and Type	Field	Description
protected tools.jackson.databind.node.ObjectNode	source

Fields inherited from class FullDocBulkRequestItem

id, index, type

Constructor Summary

Constructors

Constructor	Description
CreateIfAbsentBulkRequestItem(String index, String type, String id, tools.jackson.databind.node.ObjectNode source)

Method Summary

Modifier and Type	Method	Description
CreateIfAbsentBulkRequestItem	copyForIndex(String newIndex)
tools.jackson.databind.node.ObjectNode	getActionAndMetaDataNode(tools.jackson.databind.ObjectMapper objectMapper, ElasticsearchCompatibility elasticsearchCompatibility)
tools.jackson.databind.node.ObjectNode	getSource()
tools.jackson.databind.node.ObjectNode	getSourceNode(tools.jackson.databind.ObjectMapper objectMapper)
void	setSource(tools.jackson.databind.node.ObjectNode source)

Methods inherited from class FullDocBulkRequestItem

getId, getIndex, getType, setId, setIndex, setType

Methods inherited from class Object

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

Field Details

source

protected tools.jackson.databind.node.ObjectNode source

Constructor Details

CreateIfAbsentBulkRequestItem

public CreateIfAbsentBulkRequestItem(String index,
 String type,
 String id,
 tools.jackson.databind.node.ObjectNode source)

Method Details

getActionAndMetaDataNode

public tools.jackson.databind.node.ObjectNode getActionAndMetaDataNode(tools.jackson.databind.ObjectMapper objectMapper,
 ElasticsearchCompatibility elasticsearchCompatibility)

getSourceNode

public tools.jackson.databind.node.ObjectNode getSourceNode(tools.jackson.databind.ObjectMapper objectMapper)

copyForIndex

public CreateIfAbsentBulkRequestItem copyForIndex(String newIndex)

Specified by:

copyForIndex in interface BulkRequestItem

Specified by:

copyForIndex in class FullDocBulkRequestItem

getSource

public tools.jackson.databind.node.ObjectNode getSource()

setSource

public void setSource(tools.jackson.databind.node.ObjectNode source)