public class IndexingManagerHelperImpl extends Object implements IndexingManagerHelper
Modifier and Type | Class and Description |
---|---|
class |
IndexingManagerHelperImpl.HistoricEntityLinkWrapper
Helper class that wraps a
HistoricEntityLink such that the methods don't need to distinguish. |
static class |
IndexingManagerHelperImpl.NoOpIndexVariableType |
Modifier and Type | Field and Description |
---|---|
protected IndexManager |
indexManager |
protected IndexVariableTypes |
indexVariableTypes |
protected org.flowable.job.service.JobServiceConfiguration |
jobServiceConfiguration |
protected com.fasterxml.jackson.databind.ObjectMapper |
objectMapper |
Constructor and Description |
---|
IndexingManagerHelperImpl(IndexManager indexManager,
org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
IndexVariableTypes indexVariableTypes) |
Modifier and Type | Method and Description |
---|---|
void |
addCaseDefinitionNameTranslations(com.fasterxml.jackson.databind.node.ObjectNode data,
String caseDefinitionId,
org.flowable.cmmn.model.Case caze,
String key) |
protected void |
addCaseDefinitionScopeInfo(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
com.fasterxml.jackson.databind.node.ObjectNode data,
String caseDefinitionId,
boolean isRoot) |
protected void |
addCaseScopeInfo(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
com.fasterxml.jackson.databind.node.ObjectNode data,
boolean historic,
String caseInstanceId,
boolean isRoot) |
void |
addCommonEntityLinkFields(org.flowable.entitylink.service.impl.persistence.entity.HistoricEntityLinkEntity entityLink,
com.fasterxml.jackson.databind.node.ObjectNode data) |
void |
addHistoricData(String type,
com.fasterxml.jackson.databind.node.ObjectNode data,
String tenantId) |
void |
addHistoricParentAndRootInformation(com.fasterxml.jackson.databind.node.ObjectNode data,
String scopeId,
String scopeType) |
void |
addHistoricVariableInstanceFields(org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity historicVariableInstance,
String scopeId,
String scopeType,
String scopeHierarchyType,
com.fasterxml.jackson.databind.node.ObjectNode data,
com.fasterxml.jackson.databind.node.ArrayNode variablesArrayNode) |
protected void |
addHistoricVariableScopeDefinitionInfo(org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity variableInstance,
com.fasterxml.jackson.databind.node.ObjectNode data) |
void |
addHistoricVariablesToData(com.fasterxml.jackson.databind.node.ObjectNode data,
String jsonFieldName,
String scopeId,
String scopeType,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
void |
addIndexingVariableFields(org.flowable.variable.api.types.ValueFields valueFields,
String scopeId,
String scopeType,
String scopeHierarchyType,
com.fasterxml.jackson.databind.node.ObjectNode data,
com.fasterxml.jackson.databind.node.ArrayNode variablesArrayNode,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
void |
addMetaDataInstanceToData(com.fasterxml.jackson.databind.node.ObjectNode data,
com.fasterxml.jackson.databind.node.ArrayNode variablesArrayNode,
com.flowable.core.content.api.MetadataInstance metadataInstance,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
void |
addParentAndRootInformation(com.fasterxml.jackson.databind.node.ObjectNode data,
boolean historic,
String scopeId,
String scopeType) |
void |
addProcessDefinitionNameTranslations(com.fasterxml.jackson.databind.node.ObjectNode data,
String processDefinitionId,
org.flowable.bpmn.model.Process process,
String key) |
protected void |
addProcessDefinitionScopeInfo(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
com.fasterxml.jackson.databind.node.ObjectNode data,
String processDefinitionId,
boolean root) |
protected void |
addProcessScopeInfo(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
com.fasterxml.jackson.databind.node.ObjectNode data,
boolean historic,
String processInstanceId,
boolean root) |
void |
addRuntimeParentAndRootInformation(com.fasterxml.jackson.databind.node.ObjectNode data,
String scopeId,
String scopeType) |
void |
addRuntimeTranslationsToData(com.fasterxml.jackson.databind.node.ObjectNode data,
String scopeId,
String scopeType) |
protected void |
addRuntimeVariableScopeDefinitionInfo(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variableInstance,
com.fasterxml.jackson.databind.node.ObjectNode data) |
void |
addRuntimeVariablesToData(com.fasterxml.jackson.databind.node.ObjectNode data,
String scopeId,
String scopeType) |
protected void |
addScopeInfo(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
com.fasterxml.jackson.databind.node.ObjectNode data,
boolean historic,
String scopeId,
String scopeType,
boolean isRoot) |
void |
addTranslationFields(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
String scopeId,
String scopeType,
String scopeHierarchyType,
com.fasterxml.jackson.databind.node.ObjectNode data,
String jsonFieldName) |
void |
addTranslationFields(Translation translation,
String scopeId,
String scopeType,
String scopeHierarchyType,
com.fasterxml.jackson.databind.node.ArrayNode translationsArrayNode) |
void |
addTranslationsToData(com.fasterxml.jackson.databind.node.ObjectNode data,
String jsonFieldName,
String scopeId,
String scopeType,
boolean historic) |
void |
addVariableInstanceFields(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variableInstance,
String scopeId,
String scopeType,
String scopeHierarchyType,
com.fasterxml.jackson.databind.node.ObjectNode data,
com.fasterxml.jackson.databind.node.ArrayNode variablesArrayNode) |
void |
addVariablesToData(com.fasterxml.jackson.databind.node.ObjectNode data,
String jsonFieldName,
List<VariableInstancesHolder> variableInstancesHolders,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
protected void |
applyJsonVariableExtractors(List<IndexMappingVariableExtractor> variableExtractors,
com.fasterxml.jackson.databind.node.ObjectNode variableData,
String variableId,
com.fasterxml.jackson.databind.node.ObjectNode data,
com.fasterxml.jackson.databind.node.ArrayNode variablesArrayNode,
boolean runtime) |
protected Long |
calculateDuration(Date endTime,
Date startTime) |
com.fasterxml.jackson.databind.node.ObjectNode |
createAndAddCaseInstanceHistoricData(String tenantId) |
com.fasterxml.jackson.databind.node.ObjectNode |
createAndAddHistoricData(String type,
String indexMappingType,
String tenantId) |
com.fasterxml.jackson.databind.node.ObjectNode |
createAndAddRootCaseInstanceHistoricData(String tenantId) |
protected List<String> |
determineVariableCopyToFields(List<IndexMappingVariableExtractor> variableExtractors,
com.fasterxml.jackson.databind.node.ObjectNode variableData) |
protected IndexVariableType |
findIndexVariableType(String typeName) |
List<VariableInstancesHolder> |
gatherHistoricVariables(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
String scopeId,
String scopeType) |
List<VariableInstancesHolder> |
gatherRuntimeVariables(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
String scopeId,
String scopeType) |
List<VariableInstancesHolder> |
gatherVariables(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
String scopeId,
String scopeType,
boolean historic) |
com.fasterxml.jackson.databind.node.ArrayNode |
getArrayNode(com.fasterxml.jackson.databind.node.ObjectNode data,
String fieldName) |
AsyncIndexingHistorySession |
getAsyncIndexingHistorySession() |
org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity |
getCaseInstance(String caseInstanceId) |
List<org.flowable.entitylink.api.EntityLink> |
getChildEntityLinks(String scopeId,
String scopeType) |
List<org.flowable.entitylink.api.history.HistoricEntityLink> |
getChildHistoricEntityLinks(String scopeId,
String scopeType) |
com.flowable.content.engine.impl.persistence.entity.ContentItemEntity |
getContentItem(String contentItemId) |
Optional<org.flowable.entitylink.api.EntityLink> |
getDirectParentEntityLink(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
boolean historic,
String referenceScopeId,
String referenceScopeType) |
List<org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity> |
getHistoricVariableInstances(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
String scopeId,
String scopeType) |
protected String |
getIndexMappingType(com.fasterxml.jackson.databind.node.ObjectNode dataNode) |
protected List<IndexMappingVariableExtractor> |
getMappingVariableExtractors(String mappingType) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingCaseInstanceData(String caseInstanceId) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingContentItemData(String contentItemId) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingData(String dataId,
String dataIdFieldName,
String type) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingDataById(String dataId,
String type) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingOrCreateAndAddCaseInstanceData(String caseInstanceId,
String tenantId) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingOrCreateAndAddContentItemData(String contentItemId,
String tenantId) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingOrCreateAndAddProcessInstanceData(String processInstanceId,
String tenantId) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingOrCreateAndAddRootCaseInstanceData(String caseInstanceId,
String tenantId) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingOrCreateAndAddRootProcessInstanceData(String processInstanceId,
String tenantId) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingOrCreateAndAddTaskData(String indexType,
String taskId,
String tenantId) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingProcessInstanceData(String processInstanceId) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingRootCaseInstanceData(String caseInstanceId) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingRootProcessInstanceData(String rootProcessInstanceData) |
com.fasterxml.jackson.databind.node.ObjectNode |
getMatchingTaskData(String indexType,
String taskId) |
com.fasterxml.jackson.databind.node.ObjectNode |
getObjectNode(com.fasterxml.jackson.databind.node.ObjectNode data,
String fieldName) |
com.fasterxml.jackson.databind.node.ArrayNode |
getOrCreateArrayNode(com.fasterxml.jackson.databind.node.ObjectNode data,
String fieldName) |
com.fasterxml.jackson.databind.node.ObjectNode |
getOrCreateHistoricData(String id,
String dataIdFieldName,
String type,
String mappingType,
String tenantId) |
com.fasterxml.jackson.databind.node.ObjectNode |
getOrCreateObjectNode(com.fasterxml.jackson.databind.node.ObjectNode data,
String fieldName) |
List<org.flowable.entitylink.api.EntityLink> |
getParentEntityLinks(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
boolean historic,
String referenceScopeId,
String referenceScopeType) |
List<VariableInstancesHolder> |
getParentVariableInstances(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
String referenceScopeId,
String referenceScopeType,
boolean historic)
The returned list will be ordered from root to the actual entity
for which the entity links were requested.
|
org.flowable.engine.impl.persistence.entity.ExecutionEntity |
getProcessInstance(String processInstanceId) |
String |
getTaskTenantId(String taskId) |
String |
getTextNode(com.fasterxml.jackson.databind.JsonNode objectNode,
String field) |
protected List<com.fasterxml.jackson.databind.node.ObjectNode> |
getVariableData(com.fasterxml.jackson.databind.node.ObjectNode data,
String field,
String variableName) |
List<com.fasterxml.jackson.databind.node.ObjectNode> |
getVariableDataObjectNodes(com.fasterxml.jackson.databind.node.ObjectNode data,
String variableName)
Finds and returns all
ObjectNode instances that represent a variable and which are part of the data parameter. |
protected String |
getVariableInstanceId(org.flowable.variable.api.types.ValueFields valueFields) |
VariableInstancesHolder |
getVariableInstancesHolderForEntityLink(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
org.flowable.entitylink.api.EntityLink entityLink,
boolean historic) |
VariableInstancesHolder |
getVariableInstancesHolderForScopeIdAndType(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
String scopeId,
String scopeType,
boolean historic) |
void |
handleRecordVariableCreate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
String scopeId,
String scopeType,
String scopeHierarchyType,
com.fasterxml.jackson.databind.node.ObjectNode data,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
protected boolean |
handleRecordVariableRemoved(String variableId,
com.fasterxml.jackson.databind.node.ObjectNode data) |
protected void |
handleRecordVariableRemoved(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
com.fasterxml.jackson.databind.node.ObjectNode data,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
protected void |
handleRecordVariableUpdate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
String scopeId,
String scopeType,
String scopeHierarchyType,
com.fasterxml.jackson.databind.node.ObjectNode data,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
boolean |
isRootCaseInstance(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance) |
boolean |
isRootHistoricCaseInstance(org.flowable.cmmn.api.history.HistoricCaseInstance caseInstance) |
boolean |
isRootHistoricProcessInstance(org.flowable.engine.history.HistoricProcessInstance processInstance) |
boolean |
isRootProcessInstance(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance) |
void |
propagateVariableChangeToChildren(String parentScopeId,
String scopeType,
String tenantId,
BiConsumer<org.flowable.entitylink.api.EntityLink,com.fasterxml.jackson.databind.node.ObjectNode> childEntityConsumer) |
void |
propagateVariableCreateToChildren(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
String parentScopeId,
String scopeType,
String tenantId,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
void |
propagateVariableRemoveToChildren(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
String parentScopeId,
String parentScopeType,
String tenantId,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
void |
propagateVariableUpdateToChildren(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
String parentScopeId,
String parentScopeType,
String tenantId,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
void |
recordMetadataInstanceCreate(com.flowable.content.engine.impl.persistence.entity.MetadataInstanceEntity metadataInstance,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
void |
recordMetadataInstanceRemove(com.flowable.content.engine.impl.persistence.entity.MetadataInstanceEntity metadataInstance,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
void |
recordMetadataInstanceUpdate(com.flowable.content.engine.impl.persistence.entity.MetadataInstanceEntity metadataInstance,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
void |
recordVariableCreate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
Date createTime,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
void |
recordVariableRemoved(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
void |
recordVariableUpdate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable,
Date updateTime,
List<PlatformIndexedDataEnhancer> indexedDataEnhancers) |
com.fasterxml.jackson.databind.node.ObjectNode |
removeObjectNodeWithId(com.fasterxml.jackson.databind.node.ArrayNode arrayNode,
String value) |
protected boolean |
removeVariableIfExists(String variableId,
com.fasterxml.jackson.databind.node.ArrayNode variables) |
VariableInstancesHolder |
resolveCmmnScope(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
String scopeId,
boolean historic) |
protected VariableInstancesHolder |
resolveRuntimeBpmnScope(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
String scopeId,
boolean historic) |
protected VariableInstancesHolder |
resolveTaskScope(org.flowable.common.engine.impl.interceptor.CommandContext commandContext,
String scopeId,
boolean historic) |
protected void |
setVariableValue(String variableInstanceId,
String variableType,
Object variableValue,
com.fasterxml.jackson.databind.node.ObjectNode indexData,
com.fasterxml.jackson.databind.node.ArrayNode variablesArrayNode,
com.fasterxml.jackson.databind.node.ObjectNode variableData,
boolean runtime) |
protected boolean |
shouldIndexMetadataInstance(com.flowable.content.engine.impl.persistence.entity.MetadataInstanceEntity metadataInstance) |
boolean |
shouldIndexVariable(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable) |
protected boolean |
variableMatchesFilter(com.fasterxml.jackson.databind.node.ObjectNode filterNode,
com.fasterxml.jackson.databind.JsonNode variableNode) |
protected IndexManager indexManager
protected com.fasterxml.jackson.databind.ObjectMapper objectMapper
protected org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration
protected IndexVariableTypes indexVariableTypes
public IndexingManagerHelperImpl(IndexManager indexManager, org.flowable.job.service.JobServiceConfiguration jobServiceConfiguration, com.fasterxml.jackson.databind.ObjectMapper objectMapper, IndexVariableTypes indexVariableTypes)
public AsyncIndexingHistorySession getAsyncIndexingHistorySession()
getAsyncIndexingHistorySession
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingDataById(String dataId, String type)
getMatchingDataById
in interface IndexingManagerHelper
public org.flowable.engine.impl.persistence.entity.ExecutionEntity getProcessInstance(String processInstanceId)
public boolean isRootProcessInstance(org.flowable.engine.impl.persistence.entity.ExecutionEntity processInstance)
public boolean isRootHistoricProcessInstance(org.flowable.engine.history.HistoricProcessInstance processInstance)
public boolean isRootCaseInstance(org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity caseInstance)
public boolean isRootHistoricCaseInstance(org.flowable.cmmn.api.history.HistoricCaseInstance caseInstance)
public org.flowable.cmmn.engine.impl.persistence.entity.CaseInstanceEntity getCaseInstance(String caseInstanceId)
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingOrCreateAndAddCaseInstanceData(String caseInstanceId, String tenantId)
getMatchingOrCreateAndAddCaseInstanceData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingOrCreateAndAddRootCaseInstanceData(String caseInstanceId, String tenantId)
getMatchingOrCreateAndAddRootCaseInstanceData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode createAndAddRootCaseInstanceHistoricData(String tenantId)
createAndAddRootCaseInstanceHistoricData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode createAndAddCaseInstanceHistoricData(String tenantId)
createAndAddCaseInstanceHistoricData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingCaseInstanceData(String caseInstanceId)
getMatchingCaseInstanceData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingRootCaseInstanceData(String caseInstanceId)
getMatchingRootCaseInstanceData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingOrCreateAndAddProcessInstanceData(String processInstanceId, String tenantId)
getMatchingOrCreateAndAddProcessInstanceData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingOrCreateAndAddRootProcessInstanceData(String processInstanceId, String tenantId)
getMatchingOrCreateAndAddRootProcessInstanceData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingProcessInstanceData(String processInstanceId)
getMatchingProcessInstanceData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingRootProcessInstanceData(String rootProcessInstanceData)
getMatchingRootProcessInstanceData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingOrCreateAndAddTaskData(String indexType, String taskId, String tenantId)
getMatchingOrCreateAndAddTaskData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingTaskData(String indexType, String taskId)
getMatchingTaskData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingOrCreateAndAddContentItemData(String contentItemId, String tenantId)
getMatchingOrCreateAndAddContentItemData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingContentItemData(String contentItemId)
getMatchingContentItemData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getMatchingData(String dataId, String dataIdFieldName, String type)
getMatchingData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ObjectNode getOrCreateHistoricData(String id, String dataIdFieldName, String type, String mappingType, String tenantId)
public com.fasterxml.jackson.databind.node.ObjectNode createAndAddHistoricData(String type, String indexMappingType, String tenantId)
createAndAddHistoricData
in interface IndexingManagerHelper
public void addHistoricData(String type, com.fasterxml.jackson.databind.node.ObjectNode data, String tenantId)
addHistoricData
in interface IndexingManagerHelper
public com.fasterxml.jackson.databind.node.ArrayNode getOrCreateArrayNode(com.fasterxml.jackson.databind.node.ObjectNode data, String fieldName)
public com.fasterxml.jackson.databind.node.ArrayNode getArrayNode(com.fasterxml.jackson.databind.node.ObjectNode data, String fieldName)
public com.fasterxml.jackson.databind.node.ObjectNode getOrCreateObjectNode(com.fasterxml.jackson.databind.node.ObjectNode data, String fieldName)
public com.fasterxml.jackson.databind.node.ObjectNode getObjectNode(com.fasterxml.jackson.databind.node.ObjectNode data, String fieldName)
public com.fasterxml.jackson.databind.node.ObjectNode removeObjectNodeWithId(com.fasterxml.jackson.databind.node.ArrayNode arrayNode, String value)
public void addRuntimeParentAndRootInformation(com.fasterxml.jackson.databind.node.ObjectNode data, String scopeId, String scopeType)
public void addHistoricParentAndRootInformation(com.fasterxml.jackson.databind.node.ObjectNode data, String scopeId, String scopeType)
public void addParentAndRootInformation(com.fasterxml.jackson.databind.node.ObjectNode data, boolean historic, String scopeId, String scopeType)
protected void addScopeInfo(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, com.fasterxml.jackson.databind.node.ObjectNode data, boolean historic, String scopeId, String scopeType, boolean isRoot)
protected void addCaseScopeInfo(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, com.fasterxml.jackson.databind.node.ObjectNode data, boolean historic, String caseInstanceId, boolean isRoot)
protected void addCaseDefinitionScopeInfo(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, com.fasterxml.jackson.databind.node.ObjectNode data, String caseDefinitionId, boolean isRoot)
public void addCaseDefinitionNameTranslations(com.fasterxml.jackson.databind.node.ObjectNode data, String caseDefinitionId, org.flowable.cmmn.model.Case caze, String key)
protected void addProcessScopeInfo(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, com.fasterxml.jackson.databind.node.ObjectNode data, boolean historic, String processInstanceId, boolean root)
protected void addProcessDefinitionScopeInfo(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, com.fasterxml.jackson.databind.node.ObjectNode data, String processDefinitionId, boolean root)
public void addProcessDefinitionNameTranslations(com.fasterxml.jackson.databind.node.ObjectNode data, String processDefinitionId, org.flowable.bpmn.model.Process process, String key)
public void recordVariableCreate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, Date createTime, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
public boolean shouldIndexVariable(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable)
public void propagateVariableCreateToChildren(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, String parentScopeId, String scopeType, String tenantId, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
propagateVariableCreateToChildren
in interface IndexingManagerHelper
public void recordVariableUpdate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, Date updateTime, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
public void propagateVariableUpdateToChildren(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, String parentScopeId, String parentScopeType, String tenantId, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
propagateVariableUpdateToChildren
in interface IndexingManagerHelper
protected void handleRecordVariableUpdate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, String scopeId, String scopeType, String scopeHierarchyType, com.fasterxml.jackson.databind.node.ObjectNode data, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
public void recordVariableRemoved(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
public void propagateVariableRemoveToChildren(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, String parentScopeId, String parentScopeType, String tenantId, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
propagateVariableRemoveToChildren
in interface IndexingManagerHelper
protected void handleRecordVariableRemoved(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, com.fasterxml.jackson.databind.node.ObjectNode data, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
protected boolean handleRecordVariableRemoved(String variableId, com.fasterxml.jackson.databind.node.ObjectNode data)
protected boolean removeVariableIfExists(String variableId, com.fasterxml.jackson.databind.node.ArrayNode variables)
public void propagateVariableChangeToChildren(String parentScopeId, String scopeType, String tenantId, BiConsumer<org.flowable.entitylink.api.EntityLink,com.fasterxml.jackson.databind.node.ObjectNode> childEntityConsumer)
propagateVariableChangeToChildren
in interface IndexingManagerHelper
public void handleRecordVariableCreate(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variable, String scopeId, String scopeType, String scopeHierarchyType, com.fasterxml.jackson.databind.node.ObjectNode data, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
public void addRuntimeVariablesToData(com.fasterxml.jackson.databind.node.ObjectNode data, String scopeId, String scopeType)
public void addHistoricVariablesToData(com.fasterxml.jackson.databind.node.ObjectNode data, String jsonFieldName, String scopeId, String scopeType, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
public void addVariablesToData(com.fasterxml.jackson.databind.node.ObjectNode data, String jsonFieldName, List<VariableInstancesHolder> variableInstancesHolders, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
public void addIndexingVariableFields(org.flowable.variable.api.types.ValueFields valueFields, String scopeId, String scopeType, String scopeHierarchyType, com.fasterxml.jackson.databind.node.ObjectNode data, com.fasterxml.jackson.databind.node.ArrayNode variablesArrayNode, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
public void addVariableInstanceFields(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variableInstance, String scopeId, String scopeType, String scopeHierarchyType, com.fasterxml.jackson.databind.node.ObjectNode data, com.fasterxml.jackson.databind.node.ArrayNode variablesArrayNode)
protected void setVariableValue(String variableInstanceId, String variableType, Object variableValue, com.fasterxml.jackson.databind.node.ObjectNode indexData, com.fasterxml.jackson.databind.node.ArrayNode variablesArrayNode, com.fasterxml.jackson.databind.node.ObjectNode variableData, boolean runtime)
protected List<String> determineVariableCopyToFields(List<IndexMappingVariableExtractor> variableExtractors, com.fasterxml.jackson.databind.node.ObjectNode variableData)
protected void applyJsonVariableExtractors(List<IndexMappingVariableExtractor> variableExtractors, com.fasterxml.jackson.databind.node.ObjectNode variableData, String variableId, com.fasterxml.jackson.databind.node.ObjectNode data, com.fasterxml.jackson.databind.node.ArrayNode variablesArrayNode, boolean runtime)
protected void addRuntimeVariableScopeDefinitionInfo(org.flowable.variable.service.impl.persistence.entity.VariableInstanceEntity variableInstance, com.fasterxml.jackson.databind.node.ObjectNode data)
public String getTextNode(com.fasterxml.jackson.databind.JsonNode objectNode, String field)
public void addHistoricVariableInstanceFields(org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity historicVariableInstance, String scopeId, String scopeType, String scopeHierarchyType, com.fasterxml.jackson.databind.node.ObjectNode data, com.fasterxml.jackson.databind.node.ArrayNode variablesArrayNode)
protected void addHistoricVariableScopeDefinitionInfo(org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity variableInstance, com.fasterxml.jackson.databind.node.ObjectNode data)
public List<VariableInstancesHolder> gatherRuntimeVariables(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, String scopeId, String scopeType)
public List<VariableInstancesHolder> gatherHistoricVariables(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, String scopeId, String scopeType)
public List<VariableInstancesHolder> gatherVariables(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, String scopeId, String scopeType, boolean historic)
protected String getVariableInstanceId(org.flowable.variable.api.types.ValueFields valueFields)
public List<VariableInstancesHolder> getParentVariableInstances(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, String referenceScopeId, String referenceScopeType, boolean historic)
public void addRuntimeTranslationsToData(com.fasterxml.jackson.databind.node.ObjectNode data, String scopeId, String scopeType)
public void addTranslationsToData(com.fasterxml.jackson.databind.node.ObjectNode data, String jsonFieldName, String scopeId, String scopeType, boolean historic)
public void addTranslationFields(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, String scopeId, String scopeType, String scopeHierarchyType, com.fasterxml.jackson.databind.node.ObjectNode data, String jsonFieldName)
public void addTranslationFields(Translation translation, String scopeId, String scopeType, String scopeHierarchyType, com.fasterxml.jackson.databind.node.ArrayNode translationsArrayNode)
public Optional<org.flowable.entitylink.api.EntityLink> getDirectParentEntityLink(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, boolean historic, String referenceScopeId, String referenceScopeType)
public List<org.flowable.entitylink.api.EntityLink> getChildEntityLinks(String scopeId, String scopeType)
public List<org.flowable.entitylink.api.history.HistoricEntityLink> getChildHistoricEntityLinks(String scopeId, String scopeType)
public List<org.flowable.entitylink.api.EntityLink> getParentEntityLinks(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, boolean historic, String referenceScopeId, String referenceScopeType)
public VariableInstancesHolder getVariableInstancesHolderForEntityLink(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, org.flowable.entitylink.api.EntityLink entityLink, boolean historic)
public VariableInstancesHolder getVariableInstancesHolderForScopeIdAndType(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, String scopeId, String scopeType, boolean historic)
protected VariableInstancesHolder resolveTaskScope(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, String scopeId, boolean historic)
protected VariableInstancesHolder resolveRuntimeBpmnScope(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, String scopeId, boolean historic)
public VariableInstancesHolder resolveCmmnScope(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, String scopeId, boolean historic)
public void recordMetadataInstanceCreate(com.flowable.content.engine.impl.persistence.entity.MetadataInstanceEntity metadataInstance, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
public void recordMetadataInstanceUpdate(com.flowable.content.engine.impl.persistence.entity.MetadataInstanceEntity metadataInstance, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
public void recordMetadataInstanceRemove(com.flowable.content.engine.impl.persistence.entity.MetadataInstanceEntity metadataInstance, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
public void addMetaDataInstanceToData(com.fasterxml.jackson.databind.node.ObjectNode data, com.fasterxml.jackson.databind.node.ArrayNode variablesArrayNode, com.flowable.core.content.api.MetadataInstance metadataInstance, List<PlatformIndexedDataEnhancer> indexedDataEnhancers)
protected boolean shouldIndexMetadataInstance(com.flowable.content.engine.impl.persistence.entity.MetadataInstanceEntity metadataInstance)
public com.flowable.content.engine.impl.persistence.entity.ContentItemEntity getContentItem(String contentItemId)
public List<org.flowable.variable.service.impl.persistence.entity.HistoricVariableInstanceEntity> getHistoricVariableInstances(org.flowable.common.engine.impl.interceptor.CommandContext commandContext, String scopeId, String scopeType)
protected IndexVariableType findIndexVariableType(String typeName)
protected String getIndexMappingType(com.fasterxml.jackson.databind.node.ObjectNode dataNode)
protected List<IndexMappingVariableExtractor> getMappingVariableExtractors(String mappingType)
protected boolean variableMatchesFilter(com.fasterxml.jackson.databind.node.ObjectNode filterNode, com.fasterxml.jackson.databind.JsonNode variableNode)
public List<com.fasterxml.jackson.databind.node.ObjectNode> getVariableDataObjectNodes(com.fasterxml.jackson.databind.node.ObjectNode data, String variableName)
ObjectNode
instances that represent a variable and which are part of the data parameter.
These variables can be in the 'created variables' array, in the 'updated variables' array
or in the regular 'variables' (e.g. on reindexing). This method will search all these possible arrays.
Also note that one variable will have multiple entries: one for the self, for the parent (optionally) and for the root.
This methods returns all those instances.getVariableDataObjectNodes
in interface IndexingManagerHelper
protected List<com.fasterxml.jackson.databind.node.ObjectNode> getVariableData(com.fasterxml.jackson.databind.node.ObjectNode data, String field, String variableName)
public void addCommonEntityLinkFields(org.flowable.entitylink.service.impl.persistence.entity.HistoricEntityLinkEntity entityLink, com.fasterxml.jackson.databind.node.ObjectNode data)
Copyright © 2019. All rights reserved.