public class EngineOperationsDao extends Dao
Modifier and Type | Class and Description |
---|---|
static class |
EngineOperationsDao.RULES_GROUPS_TYPE |
TABLE_NAME_PREFIX
Constructor and Description |
---|
EngineOperationsDao() |
Modifier and Type | Method and Description |
---|---|
void |
queueGraphForDeletion(Integer graphId)
Marks graph for deletion by Engine.
|
void |
rerunGraph(Integer graphId)
Updates DB contents to signal Engine to rerun pipeline on graph with the given id.
|
void |
rerunGraphsForPipeline(Integer pipelineId)
Updates DB contents to signal Engine to rerun all graphs associated with the pipeline given by id.
|
void |
rerunGraphsForRulesGroup(String assignmentTableName,
Integer groupId)
Updates DB contents to signal Engine to rerun all graphs associated with all pipelines
that have a transformer which is assigned the rule group given by id.
|
boolToSmallint, createVirtuosoConnectionWrapper, executeInTransaction, getLookupFactory, jdbcQuery, jdbcQuery, jdbcQueryForInt, jdbcQueryForInt, jdbcQueryForInt, jdbcQueryForList, jdbcQueryForObject, jdbcQueryForObject, jdbcQueryForObject, jdbcQueryForObject, jdbcUpdate, jdbcUpdate, jdbcUpdate, setDaoLookupFactory
public void rerunGraphsForPipeline(Integer pipelineId) throws Exception
pipelineId
- Exception
public void rerunGraphsForRulesGroup(String assignmentTableName, Integer groupId) throws Exception
assignmentDao
- groupId
- Exception
public void rerunGraph(Integer graphId) throws Exception
graphId
- ID of graph to re-run pipeline onException
Copyright © 2013. All Rights Reserved.