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.EntityLink, IndexingContext.IdentityLink

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String,CaseDefinition>	caseDefinitions
protected final Map<String,HistoricCaseInstance>	caseInstances
protected final CommandContext	commandContext
protected String	currentMappingType
protected String	currentTenantId
protected final Map<String,Map<String,Map<String,HistoricVariableInstanceEntity>>>	historicVariableInstancesCache
protected final Map<String,Map<String,List<IndexingContext.IdentityLink>>>	identityLinksCache
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,ProcessDefinition>	processDefinitions
protected final Map<String,HistoricProcessInstance>	processInstances
protected final Map<String,HistoricTaskInstance>	taskInstances
protected final Map<String,Map<String,List<Translation>>>	translationsCache

Constructor Summary

Constructors

Constructor	Description
IndexingContextImpl(CommandContext commandContext, IndexManager indexManager, List<HistoricCaseInstance> caseInstances, List<HistoricProcessInstance> processInstances, List<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(BpmnModel bpmnModel, String processDefinitionKey)
protected VariableIndexingFilter	createIndexingFilter(CmmnModel cmmnModel, String caseDefinitionKey)
protected VariableIndexingFilter	createProcessDefinitionIndexingFilter(String processDefinitionId)
protected Map<String,HistoricVariableInstanceEntity>	fetchHistoricVariableInstances(String scopeId, String scopeType)
protected List<IndexMappingVariableExtractor>	fetchIndexMappingVariableExtractors(String mappingType, String tenantId)
VariableIndexingFilter	findScopedIndexingFilter(String scopeId, String scopeType)
static IndexingContextImpl	forCases(CommandContext commandContext, IndexManager indexManager, List<HistoricCaseInstance> caseInstances)
static IndexingContextImpl	forProcesses(CommandContext commandContext, IndexManager indexManager, List<HistoricProcessInstance> processInstances)
CaseDefinition	getCaseDefinition(String caseDefinitionId)
protected static Map<String,CaseDefinition>	getCaseDefinitions(Set<String> definitionIds, CommandContext commandContext)
CommandContext	getCommandContext()
protected <T> List<String>	getExtensionElementValues(List<T> extensionList, Function<T,String> valueSupplier)
HistoricCaseInstance	getHistoricCaseInstance(String caseInstanceId)
HistoricProcessInstance	getHistoricProcessInstance(String processInstanceId)
HistoricTaskInstance	getHistoricTask(String taskInstanceId, String scopeType)
Map<String,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, CommandContext commandContext)
List<IndexMappingVariableExtractor>	getIndexMappingVariableExtractors()
protected List<String>	getIndexNamesForMappingType(String mappingType)
protected List<IndexMappingVariableExtractor>	getMappingVariableExtractors(String mappingType)
IndexingContext.EntityLink	getParentEntityLink(String referenceScopeId, String referenceScopeType)
ProcessDefinition	getProcessDefinition(String processDefinitionId)
protected static Map<String,ProcessDefinition>	getProcessDefinitions(Set<String> definitionIds, CommandContext commandContext)
List<Translation>	getTranslations(String scopeId, String scopeType)
protected static Map<String,List<Translation>>	getTranslationsByScope(String scopeType, Collection<String> scopeIds, CommandContext commandContext)
protected static Map<String,Map<String,HistoricVariableInstanceEntity>>	getVariablesByScope(String scopeType, Set<String> scopeIds, 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 CommandContext commandContext

indexManager

protected final IndexManager indexManager

historicVariableInstancesCache

protected final Map<String,Map<String,Map<String,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,HistoricCaseInstance> caseInstances

processInstances

protected final Map<String,HistoricProcessInstance> processInstances

taskInstances

protected final Map<String,HistoricTaskInstance> taskInstances

caseDefinitions

protected final Map<String,CaseDefinition> caseDefinitions

processDefinitions

protected final Map<String,ProcessDefinition> processDefinitions

currentMappingType

protected String currentMappingType

currentTenantId

protected String currentTenantId

Constructor Details

IndexingContextImpl

public IndexingContextImpl(CommandContext commandContext,
 IndexManager indexManager,
 List<HistoricCaseInstance> caseInstances,
 List<HistoricProcessInstance> processInstances,
 List<HistoricTaskInstance> taskInstances)

Method Details

getTranslationsByScope

protected static Map<String,List<Translation>> getTranslationsByScope(String scopeType,
 Collection<String> scopeIds,
 CommandContext commandContext)

getHistoricProcessInstance

public HistoricProcessInstance getHistoricProcessInstance(String processInstanceId)

Specified by:

getHistoricProcessInstance in interface IndexingContext

getHistoricCaseInstance

public HistoricCaseInstance getHistoricCaseInstance(String caseInstanceId)

Specified by:

getHistoricCaseInstance in interface IndexingContext

getHistoricTask

public HistoricTaskInstance getHistoricTask(String taskInstanceId,
 String scopeType)

Specified by:

getHistoricTask in interface IndexingContext

getCaseDefinition

public CaseDefinition getCaseDefinition(String caseDefinitionId)

Specified by:

getCaseDefinition in interface IndexingContext

getProcessDefinition

public ProcessDefinition getProcessDefinition(String processDefinitionId)

Specified by:

getProcessDefinition in interface IndexingContext

getHistoricVariableInstances

public Map<String,HistoricVariableInstanceEntity> getHistoricVariableInstances(String scopeId,
 String scopeType)

Specified by:

getHistoricVariableInstances in interface IndexingContext

fetchHistoricVariableInstances

protected Map<String,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(BpmnModel bpmnModel,
 String processDefinitionKey)

createIndexingFilter

protected VariableIndexingFilter createIndexingFilter(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 CommandContext getCommandContext()

Specified by:

getCommandContext in interface IndexingContext

setCurrentMappingType

public void setCurrentMappingType(String currentMappingType)

setCurrentTenantId

public void setCurrentTenantId(String currentTenantId)

forCases

public static IndexingContextImpl forCases(CommandContext commandContext,
 IndexManager indexManager,
 List<HistoricCaseInstance> caseInstances)

forProcesses

public static IndexingContextImpl forProcesses(CommandContext commandContext,
 IndexManager indexManager,
 List<HistoricProcessInstance> processInstances)

getVariablesByScope

protected static Map<String,Map<String,HistoricVariableInstanceEntity>> getVariablesByScope(String scopeType,
 Set<String> scopeIds,
 CommandContext commandContext)

getIdentityLinksByScope

protected static Map<String,List<IndexingContext.IdentityLink>> getIdentityLinksByScope(String scopeType,
 Collection<String> scopeIds,
 CommandContext commandContext)

getCaseDefinitions

protected static Map<String,CaseDefinition> getCaseDefinitions(Set<String> definitionIds,
 CommandContext commandContext)

getProcessDefinitions

protected static Map<String,ProcessDefinition> getProcessDefinitions(Set<String> definitionIds,
 CommandContext commandContext)