|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object atg.nucleus.logging.VariableArgumentApplicationLoggingImpl atg.nucleus.GenericService atg.repository.search.indexing.LoaderImpl atg.repository.search.indexing.BulkLoaderImpl
public class BulkLoaderImpl
Implements BulkLoader to load do a full load of repository.
Created: February 16 2005
Field Summary | |
---|---|
static java.lang.String |
CLASS_VERSION
Class version string |
Fields inherited from class atg.nucleus.GenericService |
---|
SERVICE_INFO_KEY |
Fields inherited from interface atg.nucleus.logging.TraceApplicationLogging |
---|
DEFAULT_LOG_TRACE_STATUS |
Fields inherited from interface atg.nucleus.logging.ApplicationLogging |
---|
DEFAULT_LOG_DEBUG_STATUS, DEFAULT_LOG_ERROR_STATUS, DEFAULT_LOG_INFO_STATUS, DEFAULT_LOG_WARNING_STATUS |
Constructor Summary | |
---|---|
BulkLoaderImpl()
|
Method Summary | |
---|---|
boolean |
anyItemOfType(java.util.Set pItems,
java.util.Set pItemTypes,
java.util.Set pIgnoredTypeCache)
Return true if set of AssetVersion items (pItems) contains at least one instance of a repository item which is of any type, or any subtype, of the types specified in pItemTypes. |
java.util.List |
assetVersionsToRepositoryItems(java.util.Collection pAssetVersions)
Return a potentially empty or null list of repository items from the collection of AssetVersion objects. |
boolean |
bulkLoad(IndexingOutputConfig pOutputConfig)
Do a bulk load, using the query pQuery for the top-level repostory items. |
boolean |
bulkLoad(IndexingOutputConfig pOutputConfig,
Query pQuery)
Do a bulk load, using the query pQuery . |
boolean |
bulkLoad(IndexingOutputConfig pOutputConfig,
Query pQuery,
DocumentSubmitterSession pDocSubSession)
Do a bulk load, using the query pQuery . |
boolean |
bulkLoadWithRetry(IndexingOutputConfig pOutputConfig,
DocumentSubmitterSession pDocSubSession,
int pTimeoutMinutes)
Attempt a bulk load, retrying if someone else is currently updating. |
java.util.Collection |
getDevelopmentLines(IndexingOutputConfig pOutputConfig)
Return the development lines to load. |
IncrementalItemQueue |
getIncrementalItemQueue()
Get the incremental item queue component, needed here to clear out incremental updates after a bulkLoad. |
atg.xml.jaxb.JaxbInvoker |
getJaxbUnmarshaller()
The jaxb unmarshaller used by IndexingOutputConfigs. |
protected Query |
getPagedQuery(RepositoryView pView,
RepositoryItemGroup pGroup,
java.lang.Object pLastRepositoryId)
Get the batched query. |
protected QueryOptions |
getPagedQueryOptions(java.lang.String pRepoIdPropName)
Get the query options for paged queries. |
int |
getPagedQuerySize()
Get query page size for the top-level query, if any. |
protected RepositoryPropertyDescriptor |
getRepositoryIdPropertyDescriptor(RepositoryItemDescriptor pItemDesc)
Return the string name of the repository id. |
boolean |
isItemOfTypeInSet(java.util.Set pTypes,
RepositoryItemDescriptor pType)
Return true of item descriptor is of a type, or subtype of a type, in the set of types. |
protected void |
loadIteration(IndexingOutputConfig pOutputConfig,
Context pContext,
Query pQuery,
DocumentSubmitterSession pDocSubSession,
RepositoryItem[] pItems)
|
protected void |
loadPagedIteration(IndexingOutputConfig pOutputConfig,
Context pContext,
Query pQuery,
DocumentSubmitterSession pDocSubSession)
Perform a page iteration over the set of top-level repository items. |
void |
setIncrementalItemQueue(IncrementalItemQueue pIncrementalItemQueue)
Set the incremental item queue component, needed here to clear out incremental updates after a bulkLoad. |
void |
setJaxbUnmarshaller(atg.xml.jaxb.JaxbInvoker pJaxbUnmarshaller)
The jaxb unmarshaller used by IndexingOutputConfigs. |
void |
setPagedQuerySize(int pPagedQuerySize)
Set query page size for the top-level query, if any. |
protected java.util.HashMap |
uriMapFromAssetVersions(java.util.Set pAssetVersions)
Return a set of version manager, versionless asset URIs corresponding to the specified AssetVersion objects. |
Methods inherited from class atg.nucleus.logging.VariableArgumentApplicationLoggingImpl |
---|
vlogDebug, vlogDebug, vlogDebug, vlogDebug, vlogError, vlogError, vlogError, vlogError, vlogInfo, vlogInfo, vlogInfo, vlogInfo, vlogTrace, vlogTrace, vlogTrace, vlogTrace, vlogWarning, vlogWarning, vlogWarning, vlogWarning |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final java.lang.String CLASS_VERSION
Constructor Detail |
---|
public BulkLoaderImpl()
Method Detail |
---|
public void setIncrementalItemQueue(IncrementalItemQueue pIncrementalItemQueue)
public IncrementalItemQueue getIncrementalItemQueue()
public void setJaxbUnmarshaller(atg.xml.jaxb.JaxbInvoker pJaxbUnmarshaller)
public atg.xml.jaxb.JaxbInvoker getJaxbUnmarshaller()
getJaxbUnmarshaller
in interface BulkLoader
public void setPagedQuerySize(int pPagedQuerySize)
public int getPagedQuerySize()
public boolean bulkLoadWithRetry(IndexingOutputConfig pOutputConfig, DocumentSubmitterSession pDocSubSession, int pTimeoutMinutes) throws IndexingException
bulkLoadWithRetry
in interface BulkLoader
pOutputConfig
- the output configuration to bulkLoadpTimeoutMinutes
- the timeout minutes.pDocSubSession
- the existing document submitter session.
if null, will create a new document submitter session.
IndexingException
public boolean bulkLoad(IndexingOutputConfig pOutputConfig) throws IndexingException
bulkLoad
in interface BulkLoader
pOutputConfig
- The output configuration
IndexingException
public boolean bulkLoad(IndexingOutputConfig pOutputConfig, Query pQuery) throws IndexingException
pQuery
.
bulkLoad
in interface BulkLoader
pOutputConfig
- The output configurationpQuery
- the query to use for bulk loading
IndexingException
protected QueryOptions getPagedQueryOptions(java.lang.String pRepoIdPropName)
pRepoIdPropName
- The repository id property name.protected Query getPagedQuery(RepositoryView pView, RepositoryItemGroup pGroup, java.lang.Object pLastRepositoryId)
pView
- the top-level repository item view.pGroup
- the top-level repository item group (if any, may be null)pLastRepositoryId
- the repository ID of the last repository item processed. Should be null the first time this method is invoked.protected RepositoryPropertyDescriptor getRepositoryIdPropertyDescriptor(RepositoryItemDescriptor pItemDesc)
protected void loadPagedIteration(IndexingOutputConfig pOutputConfig, Context pContext, Query pQuery, DocumentSubmitterSession pDocSubSession) throws IndexingException, RepositoryException
IndexingException
RepositoryException
protected void loadIteration(IndexingOutputConfig pOutputConfig, Context pContext, Query pQuery, DocumentSubmitterSession pDocSubSession, RepositoryItem[] pItems) throws IndexingException, RepositoryException
pOutputConfig
- the output configurationpContext
- the indexing contextpQuery
- optional query to select top-level items (may be null)pDocSubSession
- the document submitter sessionpItems
- an optional array of items to index, if already calculated
IndexingException
RepositoryException
public java.util.List assetVersionsToRepositoryItems(java.util.Collection pAssetVersions)
pAssetVersions
- the AssetVersion collection
public boolean bulkLoad(IndexingOutputConfig pOutputConfig, Query pQuery, DocumentSubmitterSession pDocSubSession) throws IndexingException
pQuery
.
bulkLoad
in interface BulkLoader
pOutputConfig
- The output configurationpQuery
- the query to use for the top-level itemspDocSubSession
- the existing document submitter session.
if null, will create a new document submitter session.
IndexingException
public java.util.Collection getDevelopmentLines(IndexingOutputConfig pOutputConfig)
public boolean isItemOfTypeInSet(java.util.Set pTypes, RepositoryItemDescriptor pType)
pTypes
- the set of typespType
- the type to test for typehoodpublic boolean anyItemOfType(java.util.Set pItems, java.util.Set pItemTypes, java.util.Set pIgnoredTypeCache)
pDevLineItems
- a set of AssetVersion items from a
development linepItemTypes
- a set of item descriptorspIgnoredTypeCache
- a set of ignored types, or nullprotected java.util.HashMap uriMapFromAssetVersions(java.util.Set pAssetVersions)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |