Package com.flowable.platform.engine.impl.indexing.cache

Class IndexingContextImpl

java.lang.Object

com.flowable.platform.engine.impl.indexing.cache.IndexingContextImpl

All Implemented Interfaces:

IndexingContext

public class IndexingContextImpl
extends Object
implements IndexingContext

Author:

Filip Hrisafov

Nested Class Summary

Nested classes/interfaces inherited from interface com.flowable.platform.engine.impl.indexing.cache.IndexingContext

IndexingContext.DefinitionAndModel<Definition,Model>, IndexingContext.EntityLink, IndexingContext.IdentityLink

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String,IndexingContext.DefinitionAndModel<org.flowable.cmmn.api.repository.CaseDefinition,org.flowable.cmmn.model.CmmnModel>>	caseDefinitionsAndModels
protected final Map<String,org.flowable.cmmn.api.history.HistoricCaseInstance>	caseInstances
protected final org.flowable.common.engine.impl.interceptor.CommandContext	commandContext
protected String	currentMappingType
protected String	currentTenantId
protected final Map<String,Map<String,Map<String,org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity>>>	historicVariableInstancesCache
protected final Map<String,Map<String,List<IndexingContext.IdentityLink>>>	identityLinksCache
protected IndexingFilterIncidentReporter	indexingFilterIncidentReporter
protected final Map<String,Map<String,VariableIndexingFilter>>	indexingFiltersCache
protected final IndexManager	indexManager
protected final Map<String,Map<String,List<IndexMappingVariableExtractor>>>	indexMappingVariableExtractorsCache
protected final Map<String,IndexingContext.DefinitionAndModel<org.flowable.engine.repository.ProcessDefinition,org.flowable.bpmn.model.BpmnModel>>	processDefinitionsAndModels
protected final Map<String,org.flowable.engine.history.HistoricProcessInstance>	processInstances
protected final Map<String,org.flowable.task.api.history.HistoricTaskInstance>	taskInstances
protected final Map<String,Map<String,List<Translation>>>	translationsCache

Constructor Summary

Constructors

Constructor	Description
IndexingContextImpl(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, IndexManager indexManager, List<org.flowable.cmmn.api.history.HistoricCaseInstance> caseInstances, List<org.flowable.engine.history.HistoricProcessInstance> processInstances, List<org.flowable.task.api.history.HistoricTaskInstance> taskInstances)

Method Summary

Modifier and Type	Method	Description
protected VariableIndexingFilter	createCaseDefinitionIndexingFilter(String caseDefinitionId)
VariableIndexingFilter	createFilter(List<String> includeList, List<String> excludeList)
protected VariableIndexingFilter	createIndexingFilter(org.flowable.bpmn.model.BpmnModel bpmnModel, String processDefinitionKey)
protected VariableIndexingFilter	createIndexingFilter(org.flowable.cmmn.model.CmmnModel cmmnModel, String caseDefinitionKey)
protected VariableIndexingFilter	createProcessDefinitionIndexingFilter(String processDefinitionId)
protected Map<String,org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity>	fetchHistoricVariableInstances(String scopeId, String scopeType)
protected List<IndexMappingVariableExtractor>	fetchIndexMappingVariableExtractors(String mappingType, String tenantId)
VariableIndexingFilter	findScopedIndexingFilter(String scopeId, String scopeType)
static IndexingContextImpl	forCases(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, IndexManager indexManager, List<org.flowable.cmmn.api.history.HistoricCaseInstance> caseInstances)
static IndexingContextImpl	forProcesses(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, IndexManager indexManager, List<org.flowable.engine.history.HistoricProcessInstance> processInstances)
IndexingContext.DefinitionAndModel<org.flowable.cmmn.api.repository.CaseDefinition,org.flowable.cmmn.model.CmmnModel>	getCaseDefinitionAndModel(String caseDefinitionId)
protected static Map<String,IndexingContext.DefinitionAndModel<org.flowable.cmmn.api.repository.CaseDefinition,org.flowable.cmmn.model.CmmnModel>>	getCaseDefinitionsAndModels(Set<String> definitionIds, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
org.flowable.common.engine.impl.interceptor.CommandContext	getCommandContext()
String	getCurrentTenantId()
protected <T> List<String>	getExtensionElementValues(List<T> extensionList, Function<T,String> valueSupplier)
org.flowable.cmmn.api.history.HistoricCaseInstance	getHistoricCaseInstance(String caseInstanceId)
org.flowable.engine.history.HistoricProcessInstance	getHistoricProcessInstance(String processInstanceId)
org.flowable.task.api.history.HistoricTaskInstance	getHistoricTask(String taskInstanceId, String scopeType)
Map<String,org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity>	getHistoricVariableInstances(String scopeId, String scopeType)
List<IndexingContext.IdentityLink>	getIdentityLinks(String scopeId, String scopeType)
protected static Map<String,List<IndexingContext.IdentityLink>>	getIdentityLinksByScope(String scopeType, Collection<String> scopeIds, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
IndexingFilterIncidentReporter	getIndexingFilterIncidentReporter()
List<IndexMappingVariableExtractor>	getIndexMappingVariableExtractors()
protected List<String>	getIndexNamesForMappingType(String mappingType)
protected List<IndexMappingVariableExtractor>	getMappingVariableExtractors(String mappingType)
IndexingContext.EntityLink	getParentEntityLink(String referenceScopeId, String referenceScopeType)
IndexingContext.DefinitionAndModel<org.flowable.engine.repository.ProcessDefinition,org.flowable.bpmn.model.BpmnModel>	getProcessDefinitionAndModel(String processDefinitionId)
protected static Map<String,IndexingContext.DefinitionAndModel<org.flowable.engine.repository.ProcessDefinition,org.flowable.bpmn.model.BpmnModel>>	getProcessDefinitions(Set<String> definitionIds, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
List<Translation>	getTranslations(String scopeId, String scopeType)
protected static Map<String,List<Translation>>	getTranslationsByScope(String scopeType, Collection<String> scopeIds, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
protected static Map<String,Map<String,org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity>>	getVariablesByScope(String scopeType, Set<String> scopeIds, org.flowable.common.engine.impl.interceptor.CommandContext commandContext)
void	setCurrentMappingType(String currentMappingType)
void	setCurrentTenantId(String currentTenantId)

Methods inherited from class java.lang.Object

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

Field Details

commandContext

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

indexManager

protected final IndexManager indexManager

historicVariableInstancesCache

protected final Map<String,Map<String,Map<String,org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity>>> historicVariableInstancesCache

translationsCache

protected final Map<String,Map<String,List<Translation>>> translationsCache

identityLinksCache

protected final Map<String,Map<String,List<IndexingContext.IdentityLink>>> identityLinksCache

indexMappingVariableExtractorsCache

protected final Map<String,Map<String,List<IndexMappingVariableExtractor>>> indexMappingVariableExtractorsCache

indexingFiltersCache

protected final Map<String,Map<String,VariableIndexingFilter>> indexingFiltersCache

caseInstances

protected final Map<String,org.flowable.cmmn.api.history.HistoricCaseInstance> caseInstances

processInstances

protected final Map<String,org.flowable.engine.history.HistoricProcessInstance> processInstances

taskInstances

protected final Map<String,org.flowable.task.api.history.HistoricTaskInstance> taskInstances

caseDefinitionsAndModels

protected final Map<String,IndexingContext.DefinitionAndModel<org.flowable.cmmn.api.repository.CaseDefinition,org.flowable.cmmn.model.CmmnModel>> caseDefinitionsAndModels

processDefinitionsAndModels

protected final Map<String,IndexingContext.DefinitionAndModel<org.flowable.engine.repository.ProcessDefinition,org.flowable.bpmn.model.BpmnModel>> processDefinitionsAndModels

currentMappingType

protected String currentMappingType

currentTenantId

protected String currentTenantId

indexingFilterIncidentReporter

protected IndexingFilterIncidentReporter indexingFilterIncidentReporter

Constructor Details

IndexingContextImpl

public IndexingContextImpl(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 IndexManager indexManager,
 List<org.flowable.cmmn.api.history.HistoricCaseInstance> caseInstances,
 List<org.flowable.engine.history.HistoricProcessInstance> processInstances,
 List<org.flowable.task.api.history.HistoricTaskInstance> taskInstances)

Method Details

getTranslationsByScope

protected static Map<String,List<Translation>> getTranslationsByScope(String scopeType,
 Collection<String> scopeIds,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

getHistoricProcessInstance

public org.flowable.engine.history.HistoricProcessInstance getHistoricProcessInstance(String processInstanceId)

Specified by:

getHistoricProcessInstance in interface IndexingContext

getHistoricCaseInstance

public org.flowable.cmmn.api.history.HistoricCaseInstance getHistoricCaseInstance(String caseInstanceId)

Specified by:

getHistoricCaseInstance in interface IndexingContext

getHistoricTask

public org.flowable.task.api.history.HistoricTaskInstance getHistoricTask(String taskInstanceId,
 String scopeType)

Specified by:

getHistoricTask in interface IndexingContext

getCaseDefinitionsAndModels

protected static Map<String,IndexingContext.DefinitionAndModel<org.flowable.cmmn.api.repository.CaseDefinition,org.flowable.cmmn.model.CmmnModel>> getCaseDefinitionsAndModels(Set<String> definitionIds,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

getProcessDefinitions

protected static Map<String,IndexingContext.DefinitionAndModel<org.flowable.engine.repository.ProcessDefinition,org.flowable.bpmn.model.BpmnModel>> getProcessDefinitions(Set<String> definitionIds,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

getHistoricVariableInstances

public Map<String,org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity> getHistoricVariableInstances(String scopeId,
 String scopeType)

Specified by:

getHistoricVariableInstances in interface IndexingContext

fetchHistoricVariableInstances

protected Map<String,org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity> fetchHistoricVariableInstances(String scopeId,
 String scopeType)

getTranslations

public List<Translation> getTranslations(String scopeId,
 String scopeType)

Specified by:

getTranslations in interface IndexingContext

getIdentityLinks

public List<IndexingContext.IdentityLink> getIdentityLinks(String scopeId,
 String scopeType)

Specified by:

getIdentityLinks in interface IndexingContext

getIndexMappingVariableExtractors

public List<IndexMappingVariableExtractor> getIndexMappingVariableExtractors()

Specified by:

getIndexMappingVariableExtractors in interface IndexingContext

fetchIndexMappingVariableExtractors

protected List<IndexMappingVariableExtractor> fetchIndexMappingVariableExtractors(String mappingType,
 String tenantId)

getIndexNamesForMappingType

protected List<String> getIndexNamesForMappingType(String mappingType)

getMappingVariableExtractors

protected List<IndexMappingVariableExtractor> getMappingVariableExtractors(String mappingType)

findScopedIndexingFilter

public VariableIndexingFilter findScopedIndexingFilter(String scopeId,
 String scopeType)

Specified by:

findScopedIndexingFilter in interface IndexingContext

createProcessDefinitionIndexingFilter

protected VariableIndexingFilter createProcessDefinitionIndexingFilter(String processDefinitionId)

createCaseDefinitionIndexingFilter

protected VariableIndexingFilter createCaseDefinitionIndexingFilter(String caseDefinitionId)

createIndexingFilter

protected VariableIndexingFilter createIndexingFilter(org.flowable.bpmn.model.BpmnModel bpmnModel,
 String processDefinitionKey)

createIndexingFilter

protected VariableIndexingFilter createIndexingFilter(org.flowable.cmmn.model.CmmnModel cmmnModel,
 String caseDefinitionKey)

getExtensionElementValues

protected <T> List<String> getExtensionElementValues(List<T> extensionList,
 Function<T,String> valueSupplier)

createFilter

public VariableIndexingFilter createFilter(List<String> includeList,
 List<String> excludeList)

getParentEntityLink

public IndexingContext.EntityLink getParentEntityLink(String referenceScopeId,
 String referenceScopeType)

Specified by:

getParentEntityLink in interface IndexingContext

getCommandContext

public org.flowable.common.engine.impl.interceptor.CommandContext getCommandContext()

Specified by:

getCommandContext in interface IndexingContext

setCurrentMappingType

public void setCurrentMappingType(String currentMappingType)

getCurrentTenantId

public String getCurrentTenantId()

Specified by:

getCurrentTenantId in interface IndexingContext

setCurrentTenantId

public void setCurrentTenantId(String currentTenantId)

forCases

public static IndexingContextImpl forCases(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 IndexManager indexManager,
 List<org.flowable.cmmn.api.history.HistoricCaseInstance> caseInstances)

forProcesses

public static IndexingContextImpl forProcesses(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
 IndexManager indexManager,
 List<org.flowable.engine.history.HistoricProcessInstance> processInstances)

getIndexingFilterIncidentReporter

public IndexingFilterIncidentReporter getIndexingFilterIncidentReporter()

Specified by:

getIndexingFilterIncidentReporter in interface IndexingContext

getVariablesByScope

protected static Map<String,Map<String,org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity>> getVariablesByScope(String scopeType,
 Set<String> scopeIds,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

getIdentityLinksByScope

protected static Map<String,List<IndexingContext.IdentityLink>> getIdentityLinksByScope(String scopeType,
 Collection<String> scopeIds,
 org.flowable.common.engine.impl.interceptor.CommandContext commandContext)

getCaseDefinitionAndModel

public IndexingContext.DefinitionAndModel<org.flowable.cmmn.api.repository.CaseDefinition,org.flowable.cmmn.model.CmmnModel> getCaseDefinitionAndModel(String caseDefinitionId)

Specified by:

getCaseDefinitionAndModel in interface IndexingContext

getProcessDefinitionAndModel

public IndexingContext.DefinitionAndModel<org.flowable.engine.repository.ProcessDefinition,org.flowable.bpmn.model.BpmnModel> getProcessDefinitionAndModel(String processDefinitionId)

Specified by:

getProcessDefinitionAndModel in interface IndexingContext