public class Context extends ItemAndSpecifierStack implements atg.repository.search.indexing.ContextStatus
The Context class is also used (via the ContextStatus interface and ContextStatusImpl object) to provide status information to the HTML Admin.
Created: February 07 2005
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CLASS_VERSION
Class version string
|
Constructor and Description |
---|
Context() |
Modifier and Type | Method and Description |
---|---|
void |
addDeletedDocumentId(java.lang.String pDocumentId)
Add a deleted Document ID to the list.
|
void |
addDeletedDocumentURL(java.lang.String pURL)
Add a deleted documnet URL to the list.
|
void |
addGeneratedDocumentId(java.lang.String pDocumentId)
Add a generated Document ID to the list.
|
void |
addGeneratedDocumentURL(java.lang.String pURL)
Add a generated documnet URL to the list.
|
TransactionDemarcation |
beginTransaction(javax.transaction.TransactionManager pTransactionManager) |
java.util.Map |
buildIterationUniqueParams()
Build the map of iteration unique parameters.
|
boolean |
containsAttribute(java.lang.String pName)
Returns true if the context attributes contains a
mapping for the specified attribute name.
|
void |
copyFrom(ItemAndSpecifierStack pItemAndSpecifierStack)
Copy property values from the specified Context.
|
void |
endTransaction()
End the current transaction.
|
PropertyAccessor |
getAccessorForPropertyPath(java.lang.String pPropertyPath)
Get the appropriate property accessor for the specified property path.
|
java.lang.Object |
getAttribute(java.lang.String pName)
Get a thread-specific attribute by name.
|
java.util.Map |
getAttributes()
Get a read-only representation of the thread-specific attributes map.
|
int |
getClaimedGeneration()
Get the change generation claimed by the current indexing update task.
|
java.lang.String |
getCurrentBaseURL()
The current base URL.
|
java.util.Locale |
getCurrentDocumentLocale()
Get the locale for the current document.
|
java.lang.String |
getCurrentURL()
Return the URL for the current document being generated.
|
PropertyAccessor |
getDefaultAccessor()
Return the default property.
|
java.util.Map |
getDevelopmentLineItems() |
atg.repository.search.indexing.DevLineIndexInfo |
getDevLineIndexInfo() |
atg.repository.search.indexing.threading.ProcessItemDispatcher |
getDispatcher() |
java.lang.String |
getDocumentId()
Return the id for the current document being generated.
|
java.lang.String |
getDocumentRepositoryId()
Get the repository id of the repository item that corresponds
to the document.
|
atg.repository.search.indexing.DocumentSubmitterSession |
getDocumentSubmitterSession()
Get the document submitter session.
|
java.lang.Object |
getGlobalAttribute(java.lang.String pName)
Get an attribute by name.
|
java.util.Map |
getGlobalAttributes()
Get a read-only representation of the attributes map.
|
atg.search.index.IndexInfo |
getIndexInfo()
Get the IndexInfo object provided by the Search Admin or null.
|
java.lang.String |
getIndexingHashValue()
The value to use for 'stringForHash' in the indexing commands.
|
IndexingOutputConfig |
getIndexingOutputConfig()
Get the indexing output config for which this context was create.
|
java.lang.String |
getIndexingOutputConfigurationPath()
Return the absolute Nucleus path for the indexing
output configuration.
|
java.lang.Long |
getIndexingStartTime()
Retrieve the value of the start of the current indexing run
|
java.util.Map |
getIterationUniqueParams()
Get the iteration unique parameters...
|
long |
getLastActivityPersistedTime()
Get the time at which lastActivity time was persisted.
|
LoaderImpl |
getLoader()
The loader that created this Context.
|
java.lang.String |
getLogicalPartitionName()
If not null, specifies which logical partition the item should be inserted into.
|
int |
getNumFailures()
The number of failures.
|
int |
getNumSuccesses()
The number of successes.
|
atg.repository.search.indexing.OutputDocumentContent |
getOutputDocumentContent()
Get the output document content object.
|
int |
getSplitValueIndex()
The split value index.
|
atg.repository.search.indexing.ContextStatusEnum |
getStatus()
Get the status for this context.
|
boolean |
hasDeletedDocumentId(java.lang.String pDocumentId)
Return whether the Document ID has already been deleted.
|
boolean |
hasDeletedDocumentURL(java.lang.String pURL)
Return whether the document URL has already been deleted .
|
boolean |
hasGeneratedDocumentId(java.lang.String pDocumentId)
Return whether the Document ID has already been generated.
|
boolean |
hasGeneratedDocumentURL(java.lang.String pURL)
Return whether the document URL has already been generated .
|
boolean |
hasIterationUniqueParams()
Return true if there are any iteration unique parameters to be
added.
|
boolean |
hasTransactionDemarcation() |
void |
incrementFailures()
Increment the number of failures.
|
void |
incrementSuccesses()
Increment the number of successes.
|
boolean |
isAllowingMultipleSubmitsPerURL()
Whether to allow multiple submits per document URL.
|
boolean |
isBulkLoad()
Whether we are currently doing a full/bulk load.
|
boolean |
isDocumentInDevLine() |
boolean |
isOnlyNonDocumentItems()
Get the onlyNonDocumentItems entry to true.
|
boolean |
isRunningInSubThread()
Whether this context is running in a sub-thread.
|
java.lang.Object |
removeAttribute(java.lang.String pName)
Remove a thread-specific attribute by name.
|
java.lang.Object |
removeGlobalAttribute(java.lang.String pName)
Remove an attribute by name.
|
void |
setAllowingMultipleSubmitsPerURL(boolean pAllowingMultipleSubmitsPerURL)
Whether to allow multiple submits per document URL.
|
void |
setAttribute(java.lang.String pName,
java.lang.Object pAttribute)
Set a thread-specific attribute by name.
|
void |
setBulkLoad(boolean pBulkLoad)
Whether we are currently doing a full/bulk load.
|
void |
setClaimedGeneration(int pClaimedGeneration)
Set the change generation claimed by the current indexing update task.
|
void |
setCurrentBaseURL(java.lang.String pCurrentBaseURL)
The current base URL.
|
void |
setCurrentDocumentLocale(java.util.Locale pCurrentDocumentLocale)
Set the locale for the current document.
|
void |
setCurrentURL(java.lang.String pURL)
Set the URL for the current document being generated.
|
void |
setDevelopmentLineItems(java.util.Map pItems) |
void |
setDevLineIndexInfo(atg.repository.search.indexing.DevLineIndexInfo pDevLineIndexInfo) |
void |
setDocumentId(java.lang.String pDocumentId)
Set the id for the current document being generated.
|
void |
setDocumentInDevLine(boolean pInDevLine) |
void |
setDocumentRepositoryId(java.lang.String pDocumentRepositoryId)
Set the repository id of the repository item that corresponds
to the document.
|
void |
setDocumentSubmitterSession(atg.repository.search.indexing.DocumentSubmitterSession pDocumentSubmitterSession)
Set the document submitter session.
|
void |
setGlobalAttribute(java.lang.String pName,
java.lang.Object pGlobalAttribute)
Set an attribute by name.
|
java.lang.Object |
setGlobalAttributeIfAbsent(java.lang.String pName,
java.lang.Object pGlobalAttribute)
Set a global attribute if it is unset.
|
void |
setIndexInfo(atg.search.index.IndexInfo pIndexInfo)
Set the IndexInfo object provided by the Search Admin.
|
void |
setIndexingHashValue(java.lang.String pValue)
The value to use for 'stringForHash' in the indexing commands.
|
void |
setIndexingOutputConfig(IndexingOutputConfig pIndexingOutputConfig)
Set the indexing output config for which this context was create.
|
void |
setIndexingStartTime(java.lang.Long pIndexingStartTime)
Set the time start time of the current indexing run.
|
void |
setIterationUniqueParams(java.util.Map pIterationUniqueParams)
Set the iteration unique parameters...
|
void |
setLastActivityPersistedTime(long pLastActivityPersistedTime)
Set the time at which lastActivity time was persisted.
|
void |
setLoader(LoaderImpl pLoader)
The loader that created this Context.
|
void |
setLogicalPartitionName(java.lang.String pLogicalPartitionName)
Sets the logical partition the item should be inserted into.
|
void |
setNumFailures(int pCount)
Set the number of failures.
|
void |
setNumSuccesses(int pCount)
Set the number of successes.
|
void |
setOnlyNonDocumentItems(boolean pOnlyNonDocumentItems)
Set the onlyNonDocumentItems property.
|
void |
setOutputDocumentContent(atg.repository.search.indexing.OutputDocumentContent pOutputDocumentContent)
Set the output document content object.
|
void |
setSplitValueIndex(int pSplitValueIndex)
The split value index.
|
void |
setStatus(atg.repository.search.indexing.ContextStatusEnum pStatus)
Set the status for this context.
|
boolean |
shouldUseDispatcher()
Whether the sub-thread proces item dispatcher should be used.
|
void |
updateLastActivityTime() |
clearParents, getAncestorCount, getAncestorItemOfType, getNthAncestor, getNthAncestorItemAndSpecifier, getParent, isInDocument, popParent, pushParent, pushParent, toString
public boolean isDocumentInDevLine()
public void setDocumentInDevLine(boolean pInDevLine)
public void setDevelopmentLineItems(java.util.Map pItems)
public java.util.Map getDevelopmentLineItems()
public void setDevLineIndexInfo(atg.repository.search.indexing.DevLineIndexInfo pDevLineIndexInfo)
public atg.repository.search.indexing.DevLineIndexInfo getDevLineIndexInfo()
public java.lang.String getCurrentURL()
getCurrentURL
in interface atg.repository.search.indexing.ContextStatus
public void setCurrentURL(java.lang.String pURL)
public java.lang.String getDocumentId()
public void setDocumentId(java.lang.String pDocumentId)
public void setCurrentBaseURL(java.lang.String pCurrentBaseURL)
public java.lang.String getCurrentBaseURL()
public java.lang.String getIndexingHashValue()
public void setIndexingHashValue(java.lang.String pValue)
pValue
- the value to use for 'stringForHash'public void setDocumentRepositoryId(java.lang.String pDocumentRepositoryId)
public java.lang.String getDocumentRepositoryId()
public PropertyAccessor getDefaultAccessor()
public PropertyAccessor getAccessorForPropertyPath(java.lang.String pPropertyPath)
public void setOutputDocumentContent(atg.repository.search.indexing.OutputDocumentContent pOutputDocumentContent)
public atg.repository.search.indexing.OutputDocumentContent getOutputDocumentContent()
public void setDocumentSubmitterSession(atg.repository.search.indexing.DocumentSubmitterSession pDocumentSubmitterSession)
public atg.repository.search.indexing.DocumentSubmitterSession getDocumentSubmitterSession()
public void setOnlyNonDocumentItems(boolean pOnlyNonDocumentItems)
public boolean isOnlyNonDocumentItems()
public boolean isAllowingMultipleSubmitsPerURL()
public void setAllowingMultipleSubmitsPerURL(boolean pAllowingMultipleSubmitsPerURL)
public java.lang.Long getIndexingStartTime()
public void setIndexingStartTime(java.lang.Long pIndexingStartTime)
pIndexingStartTime
- - a long representing the time
of the start of the indexing run.public void setGlobalAttribute(java.lang.String pName, java.lang.Object pGlobalAttribute)
pName
- the name of the global attribute.pGlobalAttribute
- the value of the global attribute.public java.lang.Object setGlobalAttributeIfAbsent(java.lang.String pName, java.lang.Object pGlobalAttribute)
pName
- the name of the global attribute.pGlobalAttribute
- the value of the global attribute.public java.lang.Object getGlobalAttribute(java.lang.String pName)
public java.lang.Object removeGlobalAttribute(java.lang.String pName)
public java.util.Map getGlobalAttributes()
public void setAttribute(java.lang.String pName, java.lang.Object pAttribute)
public java.lang.Object getAttribute(java.lang.String pName)
public boolean containsAttribute(java.lang.String pName)
public java.lang.Object removeAttribute(java.lang.String pName)
public java.util.Map getAttributes()
public void addGeneratedDocumentURL(java.lang.String pURL)
public boolean hasGeneratedDocumentURL(java.lang.String pURL)
pURL
- The URL to check for previous generation.public void addDeletedDocumentURL(java.lang.String pURL)
public boolean hasDeletedDocumentURL(java.lang.String pURL)
pURL
- The URL to check for previous generation.public void addGeneratedDocumentId(java.lang.String pDocumentId)
pDocumentId
- the document id that has been generated.public boolean hasGeneratedDocumentId(java.lang.String pDocumentId)
pDocumentId
- The document id to check for previous generation.public void addDeletedDocumentId(java.lang.String pDocumentId)
pDocumentId
- the document id that has been deleted.public boolean hasDeletedDocumentId(java.lang.String pDocumentId)
pDocumentId
- The document id to check for previous deletion.public void setLastActivityPersistedTime(long pLastActivityPersistedTime)
public long getLastActivityPersistedTime()
getLastActivityPersistedTime
in interface atg.repository.search.indexing.ContextStatus
public void setClaimedGeneration(int pClaimedGeneration)
public int getClaimedGeneration()
getClaimedGeneration
in interface atg.repository.search.indexing.ContextStatus
public void setIndexingOutputConfig(IndexingOutputConfig pIndexingOutputConfig)
public IndexingOutputConfig getIndexingOutputConfig()
public void setIterationUniqueParams(java.util.Map pIterationUniqueParams)
public java.util.Map getIterationUniqueParams()
public boolean hasIterationUniqueParams()
public java.util.Map buildIterationUniqueParams()
public void setSplitValueIndex(int pSplitValueIndex)
public int getSplitValueIndex()
public void setCurrentDocumentLocale(java.util.Locale pCurrentDocumentLocale)
public java.util.Locale getCurrentDocumentLocale()
public int getNumSuccesses()
getNumSuccesses
in interface atg.repository.search.indexing.ContextStatus
public void setNumSuccesses(int pCount)
public void incrementSuccesses()
public int getNumFailures()
getNumFailures
in interface atg.repository.search.indexing.ContextStatus
public void setNumFailures(int pCount)
public void incrementFailures()
public void setStatus(atg.repository.search.indexing.ContextStatusEnum pStatus)
public atg.repository.search.indexing.ContextStatusEnum getStatus()
getStatus
in interface atg.repository.search.indexing.ContextStatus
public void setBulkLoad(boolean pBulkLoad)
public boolean isBulkLoad()
public void setLoader(LoaderImpl pLoader)
public LoaderImpl getLoader()
public java.lang.String getIndexingOutputConfigurationPath()
getIndexingOutputConfigurationPath
in interface atg.repository.search.indexing.ContextStatus
public void updateLastActivityTime() throws IndexingException
IndexingException
public atg.search.index.IndexInfo getIndexInfo()
getIndexInfo
in interface atg.repository.search.indexing.ContextStatus
public void setIndexInfo(atg.search.index.IndexInfo pIndexInfo)
public boolean hasTransactionDemarcation()
public TransactionDemarcation beginTransaction(javax.transaction.TransactionManager pTransactionManager) throws TransactionDemarcationException
TransactionDemarcationException
public void endTransaction() throws TransactionDemarcationException
TransactionDemarcationException
public boolean isRunningInSubThread()
public boolean shouldUseDispatcher()
public atg.repository.search.indexing.threading.ProcessItemDispatcher getDispatcher()
public java.lang.String getLogicalPartitionName()
atg.repository.search.indexing.sharder.LiveIndexingSharder
.atg.repository.search.routing.beans.LogicalPartition
public void setLogicalPartitionName(java.lang.String pLogicalPartitionName)
atg.repository.search.indexing.sharder.LiveIndexingSharder
.atg.repository.search.routing.beans.LogicalPartition
public void copyFrom(ItemAndSpecifierStack pItemAndSpecifierStack)
copyFrom
in class ItemAndSpecifierStack
pItemAndSpecifierStack
- the object from which to copy. Must
be an instance of Context.