com.flowable.indexing.job.history.async

Class BulkIndexingSession

java.lang.Object

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

All Implemented Interfaces:

Session

public class BulkIndexingSession
extends Object
implements Session

Field Summary

Fields

Modifier and Type	Field and Description
protected List<BulkIndexRequestInterceptor>	bulkIndexRequestInterceptors
protected BulkRequest	bulkRequest
protected CommandContext	commandContext
protected ElasticsearchCompatibility	elasticsearchCompatibility
protected com.fasterxml.jackson.databind.ObjectMapper	objectMapper
protected Map<String,Set<String>>	registeredFullIndexes
protected org.elasticsearch.client.RestHighLevelClient	restClient

Constructor Summary

Constructors

Constructor and Description
BulkIndexingSession(CommandContext commandContext, com.fasterxml.jackson.databind.ObjectMapper objectMapper, org.elasticsearch.client.RestHighLevelClient restClient, ElasticsearchCompatibility elasticsearchCompatibility, List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors)

Method Summary

Modifier and Type	Method and Description
void	close()
protected void	ensureBulkRequestInitialized()
org.elasticsearch.action.bulk.BulkResponse	executeBulkRequest()
void	flush()
BulkRequest	getBulkRequest()
void	indexData(String index, String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode)
void	indexDataWithExternalVersion(String index, String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode, long version)
boolean	isFullIndexRegistered(String type, String id)
protected <Resp> Resp	parseEntity(org.apache.http.HttpEntity entity, org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,IOException> entityParser)
void	registerFullIndex(String type, String id)
void	retryFailedBulkRequest(com.fasterxml.jackson.databind.node.ObjectNode actionNode, com.fasterxml.jackson.databind.node.ObjectNode sourceNode)
void	upsertData(String index, String id, com.fasterxml.jackson.databind.node.ObjectNode objectNode)
void	upsertDataWithScript(String index, String id, com.fasterxml.jackson.databind.node.ObjectNode upsertDocNode, com.fasterxml.jackson.databind.node.ObjectNode scriptNode)

Methods inherited from class java.lang.Object

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

Field Detail

commandContext

protected CommandContext commandContext

objectMapper

protected com.fasterxml.jackson.databind.ObjectMapper objectMapper

restClient

protected org.elasticsearch.client.RestHighLevelClient restClient

elasticsearchCompatibility

protected ElasticsearchCompatibility elasticsearchCompatibility

bulkIndexRequestInterceptors

protected List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors

bulkRequest

protected BulkRequest bulkRequest

registeredFullIndexes

protected Map<String,Set<String>> registeredFullIndexes

Constructor Detail

BulkIndexingSession

public BulkIndexingSession(CommandContext commandContext,
                           com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                           org.elasticsearch.client.RestHighLevelClient restClient,
                           ElasticsearchCompatibility elasticsearchCompatibility,
                           List<BulkIndexRequestInterceptor> bulkIndexRequestInterceptors)

Method Detail

upsertData

public void upsertData(String index,
                       String id,
                       com.fasterxml.jackson.databind.node.ObjectNode objectNode)

upsertDataWithScript

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

indexData

public void indexData(String index,
                      String id,
                      com.fasterxml.jackson.databind.node.ObjectNode objectNode)

indexDataWithExternalVersion

public void indexDataWithExternalVersion(String index,
                                         String id,
                                         com.fasterxml.jackson.databind.node.ObjectNode objectNode,
                                         long version)

registerFullIndex

public void registerFullIndex(String type,
                              String id)

isFullIndexRegistered

public boolean isFullIndexRegistered(String type,
                                     String id)

retryFailedBulkRequest

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

executeBulkRequest

public org.elasticsearch.action.bulk.BulkResponse executeBulkRequest()
                                                              throws IOException

Throws:

IOException

parseEntity

protected <Resp> Resp parseEntity(org.apache.http.HttpEntity entity,
                                  org.elasticsearch.common.CheckedFunction<org.elasticsearch.common.xcontent.XContentParser,Resp,IOException> entityParser)
                           throws IOException

Throws:

IOException

ensureBulkRequestInitialized

protected void ensureBulkRequestInitialized()

flush

public void flush()

Specified by:

flush in interface Session

close

public void close()

Specified by:

close in interface Session

getBulkRequest

public BulkRequest getBulkRequest()