public class WorkflowManagerDataSourceIndex extends Object implements Index, QueryService
A queriable index for querying for original cas-workflow instance metadata (not for cas-workflow2)
Modifier and Type | Field and Description |
---|---|
protected DataSource |
dataSource |
Constructor and Description |
---|
WorkflowManagerDataSourceIndex(String user,
String pass,
String driver,
String jdbcUrl) |
Modifier and Type | Method and Description |
---|---|
Map<TransactionId<?>,List<TermBucket>> |
getBuckets(List<TransactionId<?>> transactionIds)
Does the same as getBuckets(TransactionId), except is performed over a list
of TransactionIds
|
List<TermBucket> |
getBuckets(TransactionId<?> transactionId)
Returns a List of TermBuckets ingested for a given TransactionId
|
List<TransactionId<?>> |
getPage(IndexPager indexPage)
Returns a list of TransactionIds associated with the
given Index page.
|
Properties |
getProperties() |
String |
getProperty(String key) |
TransactionIdFactory |
getTransactionIdFactory() |
boolean |
hasTransactionId(TransactionId<?> transactionId) |
List<IngestReceipt> |
query(QueryExpression queryExpression)
Returns all the TransactionIds that fall under the given query
|
List<IngestReceipt> |
query(QueryExpression queryExpression,
int startIndex,
int endIndex)
Returns the results of the given query such that: [startIndex, endIndex)
|
int |
sizeOf(QueryExpression queryExpression)
Returns the number of results found for the given query
|
protected DataSource dataSource
public WorkflowManagerDataSourceIndex(String user, String pass, String driver, String jdbcUrl) throws InstantiationException
InstantiationException
public List<TransactionId<?>> getPage(IndexPager indexPage) throws CatalogIndexException
Index
getPage
in interface Index
indexPage
- The page for which TransactionIds will be returnedCatalogIndexException
public Properties getProperties() throws CatalogIndexException
getProperties
in interface Index
CatalogIndexException
public String getProperty(String key) throws CatalogIndexException
getProperty
in interface Index
CatalogIndexException
public TransactionIdFactory getTransactionIdFactory() throws CatalogIndexException
getTransactionIdFactory
in interface Index
CatalogIndexException
public boolean hasTransactionId(TransactionId<?> transactionId) throws CatalogIndexException
hasTransactionId
in interface Index
CatalogIndexException
public List<TermBucket> getBuckets(TransactionId<?> transactionId) throws QueryServiceException
QueryService
getBuckets
in interface QueryService
transactionId
- The TransactionId in questionQueryServiceException
public Map<TransactionId<?>,List<TermBucket>> getBuckets(List<TransactionId<?>> transactionIds) throws QueryServiceException
QueryService
getBuckets
in interface QueryService
transactionIds
- A List of TransactionIds for which TermBuckets are wantedQueryServiceException
public List<IngestReceipt> query(QueryExpression queryExpression) throws QueryServiceException
QueryService
query
in interface QueryService
QueryServiceException
public List<IngestReceipt> query(QueryExpression queryExpression, int startIndex, int endIndex) throws QueryServiceException
QueryService
query
in interface QueryService
queryExpression
- The query for which results will be returnedstartIndex
- The start index of subset of results to be returnedendIndex
- The end index of the subset of results to be returnedQueryServiceException
- on an errorpublic int sizeOf(QueryExpression queryExpression) throws QueryServiceException
QueryService
sizeOf
in interface QueryService
queryExpression
- The query whose size in questionQueryServiceException
- on an errorCopyright © 1999-2014 Apache OODT. All Rights Reserved.