Class BulkIndexingSession

java.lang.Object

com.flowable.indexing.job.history.async.BulkIndexingSession

All Implemented Interfaces:

org.flowable.common.engine.impl.interceptor.Session

public class BulkIndexingSession
extends Object
implements org.flowable.common.engine.impl.interceptor.Session

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<String, LowLevelIndexingService.BulkIndexRequestConflictHandler>	bulkIndexRequestConflictHandlers
protected List<BulkIndexRequestInterceptor>	bulkIndexRequestInterceptors
protected BulkRequest	bulkRequest
protected org.flowable.common.engine.impl.interceptor.CommandContext	commandContext
protected ElasticsearchClient	elasticsearchClient
protected tools.jackson.databind.ObjectMapper	objectMapper
protected Map<String, Set<String>>	registeredFullIndexes
protected ReindexActiveAliasResolver	reindexActiveAliasResolver
protected long	timestamp

Constructor Summary

Constructors

Constructor	Description
BulkIndexingSession(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, tools.jackson.databind.ObjectMapper objectMapper, ElasticsearchClient elasticsearchClient, List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors, ReindexActiveAliasResolver reindexActiveAliasResolver)

Method Summary

Modifier and Type	Method	Description
void	addRequestItem(BulkRequestItem item)
void	close()
void	createIfAbsentData(String index, String type, String id, tools.jackson.databind.node.ObjectNode objectNode)
protected void	ensureBulkRequestInitialized()
ElasticsearchBulkResponse	executeBulkRequest()
void	flush()
BulkRequest	getBulkRequest()
List<BulkRequestItem>	getBulkRequestItems()
LowLevelIndexingService.BulkIndexRequestConflictHandler	getConflictHandler(String type)
void	indexData(String index, String type, String id, tools.jackson.databind.node.ObjectNode objectNode)
void	indexDataWithExternalVersion(String index, String type, String id, tools.jackson.databind.node.ObjectNode objectNode)
boolean	isFullIndexRegistered(String type, String id)
void	registerFullIndex(String type, String id)
void	registerFullIndexWithExternalVersion(String type, String id, LowLevelIndexingService.BulkIndexRequestConflictHandler bulkIndexRequestConflictHandler)
void	retryFailedBulkRequest(tools.jackson.databind.node.ObjectNode actionNode, tools.jackson.databind.node.ObjectNode sourceNode)
void	upsertData(String index, String type, String id, tools.jackson.databind.node.ObjectNode objectNode)
void	upsertDataWithScript(String index, String id, tools.jackson.databind.node.ObjectNode upsertDocNode, tools.jackson.databind.node.ObjectNode scriptNode)

Methods inherited from class Object

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

Field Details

commandContext

protected org.flowable.common.engine.impl.interceptor.CommandContext commandContext

objectMapper

protected tools.jackson.databind.ObjectMapper objectMapper

elasticsearchClient

protected ElasticsearchClient elasticsearchClient

bulkIndexRequestInterceptors

protected List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors

reindexActiveAliasResolver

protected ReindexActiveAliasResolver reindexActiveAliasResolver

bulkRequest

protected BulkRequest bulkRequest

registeredFullIndexes

protected Map<String, Set<String>> registeredFullIndexes

bulkIndexRequestConflictHandlers

protected Map<String, LowLevelIndexingService.BulkIndexRequestConflictHandler> bulkIndexRequestConflictHandlers

timestamp

protected long timestamp

Constructor Details

BulkIndexingSession

public BulkIndexingSession(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 tools.jackson.databind.ObjectMapper objectMapper,
 ElasticsearchClient elasticsearchClient,
 List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors,
 ReindexActiveAliasResolver reindexActiveAliasResolver)

Method Details

addRequestItem

public void addRequestItem(BulkRequestItem item)

upsertData

public void upsertData(String index,
 String type,
 String id,
 tools.jackson.databind.node.ObjectNode objectNode)

upsertDataWithScript

public void upsertDataWithScript(String index,
 String id,
 tools.jackson.databind.node.ObjectNode upsertDocNode,
 tools.jackson.databind.node.ObjectNode scriptNode)

indexData

public void indexData(String index,
 String type,
 String id,
 tools.jackson.databind.node.ObjectNode objectNode)

createIfAbsentData

public void createIfAbsentData(String index,
 String type,
 String id,
 tools.jackson.databind.node.ObjectNode objectNode)

indexDataWithExternalVersion

public void indexDataWithExternalVersion(String index,
 String type,
 String id,
 tools.jackson.databind.node.ObjectNode objectNode)

registerFullIndex

public void registerFullIndex(String type,
 String id)

registerFullIndexWithExternalVersion

public void registerFullIndexWithExternalVersion(String type,
 String id,
 LowLevelIndexingService.BulkIndexRequestConflictHandler bulkIndexRequestConflictHandler)

getConflictHandler

public LowLevelIndexingService.BulkIndexRequestConflictHandler getConflictHandler(String type)

isFullIndexRegistered

public boolean isFullIndexRegistered(String type,
 String id)

retryFailedBulkRequest

public void retryFailedBulkRequest(tools.jackson.databind.node.ObjectNode actionNode,
 tools.jackson.databind.node.ObjectNode sourceNode)

executeBulkRequest

public ElasticsearchBulkResponse executeBulkRequest()

ensureBulkRequestInitialized

protected void ensureBulkRequestInitialized()

flush

public void flush()

Specified by:

flush in interface org.flowable.common.engine.impl.interceptor.Session

close

public void close()

Specified by:

close in interface org.flowable.common.engine.impl.interceptor.Session

getBulkRequest

public BulkRequest getBulkRequest()

getBulkRequestItems

public List<BulkRequestItem> getBulkRequestItems()