public class EndecaIndexingOutputConfig extends IndexingOutputConfig implements atg.endeca.index.ExtendedIndexable
In addition, "merges" duplicate equivalent meta/text properties by suppressing the text property, since Endeca properties only have on namespace (as opposed to ATG search properties, which have a separate meta and text namespace).
Created: November 09 2011
PropertyNameMunger,
OutputPropertyMerger,
Serialized Form| Modifier and Type | Class and Description |
|---|---|
class |
EndecaIndexingOutputConfig.ContextStatusReporter
Return a status reporter that wraps a Context.
|
static interface |
EndecaIndexingOutputConfig.LoaderResultsWrapper
A interface wrapper around loader results.
|
| Modifier and Type | Field and Description |
|---|---|
static java.lang.String |
CLASS_VERSION
Class version string
|
static java.lang.String |
CONTEXT_STATUS_REPORTER |
static java.lang.String[] |
ENDECA_REQUIRED_DOCUMENT_OUTPUT_PROPERTIES
The list of output properties required for documents.
|
static java.lang.String[] |
ENDECA_REQUIRED_EVERY_ITEM_OUTPUT_PROPERTIES |
protected java.util.Set<atg.repository.search.indexing.specifier.OutputProperty> |
mSetOutputProperties
The set of known output properties.
|
DEFAULT_DERIVED_PROPERTIES_MODIFIER, DEFAULT_SITE_INDEX_INFO_SERVICE, mDocumentLevelOutputProperties, mDocumentSubmitterTL, mEveryItemOutputProperties, mJobId, REQUIRED_DOCUMENT_OUTPUT_PROPERTIES, REQUIRED_EVERY_ITEM_OUTPUT_PROPERTIESSERVICE_INFO_KEYBASE_URL_OUTPUT_PROPERTY_NAME, CONTEXT_OUTPUT_PROPERTY_NAME, CURRENT_APPLICATION_KEY_CONTEXT_ATTRIBUTE_NAME, DEFAULT_FORMATTER_KEY, DELETED_ITEM_CONTEXT_ATTRIBUTE_NAME, DOCUMENT_ID_OUTPUT_PROPERTY_NAME, ENDECA_CONTEXT_LOCALE_STRING, ENDECA_CONTEXT_NAME_VALUE_SEPARATOR, ENDECA_PROP_MULTI_CONTEXT_SEPARATOR, ENDECA_PROPERTY_CONTEXT_SEPARATOR, GROUPING_CONTEXT_ATTRIBUTE_NAME, ITEM_DESCRIPTOR_OUTPUT_PROPERTY_NAME, PROP_TYPE_BOOLEAN, PROP_TYPE_DATE, PROP_TYPE_ENUM, PROP_TYPE_FLOAT, PROP_TYPE_INTEGER, PROP_TYPE_STRING, PROP_TYPE_TEXT, PROP_TYPE_UNKNOWN, REPOSITORY_NAME_OUTPUT_PROPERTY_NAME, SITE_CONTEXT_ATTRIBUTE_NAME, SITE_CONTEXT_PROPERTY_NAME, URL_OUTPUT_PROPERTY_NAMEDEFAULT_LOG_TRACE_STATUSDEFAULT_LOG_DEBUG_STATUS, DEFAULT_LOG_ERROR_STATUS, DEFAULT_LOG_INFO_STATUS, DEFAULT_LOG_WARNING_STATUS| Constructor and Description |
|---|
EndecaIndexingOutputConfig()
Createa new instance, setting the default formatter to
an instance of
EndecaPropertyFormatter |
| Modifier and Type | Method and Description |
|---|---|
protected void |
addDefaultOutputNameReplacements()
Add the default output name replacements.
|
protected java.lang.String[] |
addInStrings(java.lang.String[] pStrings,
java.lang.String[] pRequiredStrings)
In this case, we are overriding the add in strings to parse out
disallowed flags, and make it smarter about not stomping all over
explicit settings.
|
void |
afterSessionStart(Context pContext)
This method is invoked immediately after a DocumentSubmitter session
is started.
|
boolean |
alwaysFlushRecordStore() |
protected void |
calculateOutputNameToOutputProperty()
Populate the sourcePropertyPathToOutputProperty property.
|
void |
calculateOutputPropertyNames()
Calculate the various output properties.
|
protected void |
calculateSourcePropertyNameToOutputProperties()
Populate the sourcePropertyPathToOutputProperty property.
|
protected void |
calculateSourcePropertyPathToOutputProperty()
Populate the sourcePropertyPathToOutputProperty property.
|
boolean |
cancel(IndexingTask pTask)
Cancel the currently in-process performBulkLoad or
processQueuedIncrementalUpdates.
|
boolean |
cancel(IndexingTask pTask,
boolean pBaseline)
Deprecated.
|
protected javax.servlet.Servlet |
createAdminServlet()
Creates and returns a new Servlet that will administer this
service.
|
protected atg.search.index.IndexInfo |
createDefaultIndexInfo()
Create default IndexInfo for indexing tasks that do no supply an
IndexInfo.
|
protected void |
createEmptyTransformationRecords(boolean pMeta,
atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier)
Create empty transformation records for all known properties.
|
protected void |
createEmptyTransformationRecords(boolean pMeta,
atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier,
java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,atg.endeca.index.PropertyTransformationRecord> pTransMap)
Create empty transformation records for all known properties.
|
protected atg.repository.search.indexing.specifier.OutputItemSpecifier |
createOutputItemSpecifier()
Returns EndecaOutputItemSpecifier that is aware of endeca-specific properties.
|
Context |
createTestContext()
Create a Context for testing or other non-indexing use.
|
atg.search.index.IndexInfo |
createTestIndexInfo()
Creates and initializes an IndexInfo instances for test document
generation.
|
void |
doStartService()
Start up the service, parsing the definition file, etc.
|
java.util.List<Record> |
generateTestRecords(java.lang.String pId)
Generate test records.
|
java.util.Map<java.lang.String,java.lang.String> |
getAncestorsPropertiesMap()
Returns property ancestorsPropertiesMap
|
atg.endeca.index.enforcer.BaselineEnforcer[] |
getBaselineEnforcers() |
java.lang.String[] |
getDisallowedRequiredFlags()
Returns property disallowedRequiredFlags.
|
java.lang.String[] |
getDocumentLevelOutputProperties()
Get the list of output properties that will be added for the is-document=true
item (from teh definition file).
|
java.lang.String[] |
getEveryItemOutputProperties()
Overwrite the strings used to generate output properties for item descriptor.
|
java.lang.String[] |
getExcludedItemsAncestorIds()
Returns property excludedItemsAncestorIds
|
atg.endeca.index.enforcer.FullExportEnforcer[] |
getFullExportEnforcers() |
java.lang.String |
getIdOutputPropertyName()
Returns property idOutputPropertyName.
|
atg.endeca.index.configuration.IndexingApplicationConfiguration |
getIndexingApplicationConfiguration()
Returns property indexingApplicationConfiguration.
|
java.util.Set<java.lang.String> |
getIndexingOutputConfigPaths()
Return the set of IndexingOutputConfigs associated with this Indexable.
|
java.util.Locale[] |
getLocales()
Returns property locales.
|
boolean |
getMultiLanguageSynonyms()
Returns property multiLanguageSynonyms
|
java.util.Map<java.lang.String,atg.repository.search.indexing.specifier.OutputProperty> |
getOutputNameToOutputProperty()
Returns property outputNameToOutputProperty.
|
java.util.List<atg.repository.search.indexing.specifier.OutputProperty> |
getOutputPropertiesAccessible(boolean pMeta)
A publically accessible form of getOutputProperties.
|
java.util.List<atg.repository.search.indexing.specifier.OutputProperty> |
getOutputPropertiesAccessible(boolean pMeta,
atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier)
A publically accessible form of getOutputProperties.
|
java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,atg.endeca.index.PropertyTransformationRecord> |
getOutputPropertyToTransformations()
Return the outputPropertyToTransformations property.
|
java.util.LinkedHashMap<java.lang.String,java.lang.String> |
getPrefixReplacementMap()
Returns property prefixReplacementMap.
|
java.lang.String[] |
getReplaceWithTypePrefixes()
Returns property replaceWithTypePrefixes.
|
java.lang.String[] |
getRequiredDocumentOutputProperties()
Get the array of required required document output properties.
|
java.lang.String[] |
getRequiredEveryItemOutputProperties()
Get an array of required output properties for every indexed
item.
|
char |
getSeparator()
Returns property mSeparator.
|
java.util.Set<atg.repository.search.indexing.specifier.OutputProperty> |
getSetOutputProperties()
Return the setOutputProperties property.
|
java.lang.String[] |
getSiteIDsToIndex()
Returns property siteIDsToIndex.
|
Repository |
getSiteRepositoryToQuery()
Return the site repository to query for all sites.
|
Repository |
getSiteRepositoryToQueryOverride()
Returns property siteRepositoryToQueryOverride.
|
RepositoryItem[] |
getSitesToIndex()
Returns property getCatalogsForSitesToIndex.
|
java.util.Map<java.lang.String,java.util.List<atg.repository.search.indexing.specifier.OutputProperty>> |
getSourcePropertyNameToOutputProperties()
Returns property sourcePropertyNameToOutputProperties.
|
java.util.Map<java.lang.String,atg.repository.search.indexing.specifier.OutputProperty> |
getSourcePropertyPathToOutputProperty()
Returns property sourcePropertyPathToOutputProperty.
|
java.util.LinkedHashMap<java.lang.String,java.lang.String> |
getSuffixReplacementMap()
Returns property suffixReplacementMap.
|
java.lang.String |
getTestRecordId() |
atg.endeca.index.PropertyTransformationRecord |
getTransformationRecord(atg.repository.search.indexing.specifier.OutputProperty pProperty)
Get the transformation record for the specified output property,
created it if needed.
|
boolean |
isAddDefaultOutputNameReplacements()
Returns property addDefaultOutputNameReplacements.
|
boolean |
isAlwaysFlushRecordStore()
Sets the alwaysFlushRecordStore value.
|
boolean |
isAlwaysGenerateXml()
Returns property alwaysGenerateXml.
|
boolean |
isForceToBaseline()
The method is called before starting partial indexing job for all Indexable
to allow forcing the job to baseline indexing.
|
boolean |
isForceToBaseline(IndexingJob pJob) |
boolean |
isForceToBaselineFullExport(IndexingJob pJob)
This method is called before starting a partial or baseline indexing job
for all Indexable to allow forcing the job to full export.
|
boolean |
isForceToBaselineOnChange()
Returns property forceToBaselineOnChange
|
boolean |
isGenerateMultiLanguageSynonyms()
Returns flag indicating whether to generate multi language synonyms
|
boolean |
isLoggingDebugPropertyMerging()
Returns property loggingDebugPropertyMerging.
|
boolean |
isNameTopLevelTypePrefixesByFirstPropertyOwner()
Returns property nameTopLevelTypePrefixesByFirstPropertyOwner.
|
boolean |
isNeededForIncremental()
Whether this Indexable is needed for an incremental update.
|
protected boolean |
isRequiredFlagDisallowed(java.lang.String pFlag)
Whether the flag form the requiredProperties or everyDocument
is disallowed.
|
boolean |
isSupportsStatusCounts()
Whether this object supports returning/updating status counts.
|
boolean |
isUseAtgSearchXmlFormat()
Returns property useAtgSearchXmlFormat.
|
boolean |
isUsePartialExportForBaselines()
Set the usePartialExportForBaselines value.
|
boolean |
isWideRecordEnabled()
Sets the wideRecordEnabled value.
|
boolean |
mayNeedCleanup()
Whether this task may need cleanup.
|
protected void |
mergeDuplicateProperties(atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier,
java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,atg.endeca.index.PropertyTransformationRecord> pOutputPropertyToTransformations)
Look for duplicate properties and suppress redundant duplicates.
|
protected void |
mungeAllOutputPropertyNames()
Munge all output property names into an Endeca-friendly format.
|
protected void |
mungeAllOutputPropertyNames(atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier,
java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,atg.endeca.index.PropertyTransformationRecord> pOutputPropertyToTransformations)
Munge all output property names into an Endeca-friendly format.
|
atg.repository.search.indexing.BulkLoaderResults |
performBaselineFullExportUpdate(IndexingTask pTask)
Do a full/bulk load plus run the baseline update script on Guided Search
side.
|
atg.repository.search.indexing.BulkLoaderResults |
performBaselineUpdate(IndexingTask pTask)
Perform a baseline update.
|
atg.repository.search.indexing.LoaderResults |
performPartialUpdate(IndexingTask pTask)
Do an incremental load (that is, process any Queued incremental
updates.
|
void |
persistInitialState(java.util.Map<java.lang.String,java.lang.Object> pBaselineState,
java.util.Map<java.lang.String,java.lang.Object> pFullExportState) |
void |
postIndexingCleanup(IndexingTask pTask,
boolean pSuccess,
atg.repository.search.indexing.LoaderResults pResults)
Perform any post indexing cleanup.
|
protected atg.repository.search.indexing.specifier.OutputItemSpecifier |
prepareOutputItemSpecifier(atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier,
java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,atg.endeca.index.PropertyTransformationRecord> pOutputPropertyToTransformations)
Prepare the specifier pSpecifier by adjusting
output property names, merging duplicate properties, etc.
|
atg.repository.search.indexing.LoaderResults |
processQueuedIncrementalUpdates(atg.search.index.IndexInfo pIndexInfo,
atg.repository.search.indexing.DocumentSubmitterSession pSession)
Process any queued incremental updates
|
void |
setAddDefaultOutputNameReplacements(boolean pAddDefaultOutputNameReplacements)
Sets property addDefaultOutputNameReplacements.
|
void |
setAlwaysFlushRecordStore(boolean value)
Gets the alwaysFlushRecordStore value.
|
void |
setAlwaysGenerateXml(boolean pAlwaysGenerateXml)
Sets property alwaysGenerateXml.
|
void |
setAncestorsPropertiesMap(java.util.Map<java.lang.String,java.lang.String> pAncestorsPropertiesMap)
Sets property ancestorsPropertiesMap
|
void |
setBaselineEnforcers(atg.endeca.index.enforcer.BaselineEnforcer[] baselineEnforcers) |
void |
setDisallowedRequiredFlags(java.lang.String[] pDisallowedRequiredFlags)
Sets property disallowedRequiredFlags.
|
void |
setExcludedItemsAncestorIds(java.lang.String[] pExcludedItemsAncestorIds)
Sets property excludedItemsAncestorIds
|
void |
setForceToBaselineOnChange(boolean pForceToBaselineOnChange)
Sets property forceToBaselineOnChange
|
void |
setFullExportEnforcers(atg.endeca.index.enforcer.FullExportEnforcer[] pFullExportEnforcers) |
void |
setGenerateMultiLanguageSynonyms(boolean pGenerateMultiLanguageSynonyms)
Sets flag indicating whether to generate multi language synonyms
|
void |
setIdOutputPropertyName(java.lang.String pIdOutputPropertyName)
Sets property idOutputPropertyName.
|
void |
setIndexingApplicationConfiguration(atg.endeca.index.configuration.IndexingApplicationConfiguration pIndexingApplicationConfiguration)
Sets property indexingApplicationConfiguration.
|
void |
setLoggingDebugPropertyMerging(boolean pLoggingDebugPropertyMerging)
Sets property loggingDebugPropertyMerging.
|
void |
setNameTopLevelTypePrefixesByFirstPropertyOwner(boolean pNameTopLevelTypePrefixesByFirstPropertyOwner)
Sets property nameTopLevelTypePrefixesByFirstPropertyOwner.
|
void |
setOutputNameToOutputProperty(java.util.Map<java.lang.String,atg.repository.search.indexing.specifier.OutputProperty> pOutputNameToOutputProperty)
Sets property outputNameToOutputProperty.
|
void |
setOutputPropertyToTransformations(java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,atg.endeca.index.PropertyTransformationRecord> pOutputPropertyToTransformations)
Set the outputPropertyToTransformations property.
|
void |
setPrefixReplacementMap(java.util.LinkedHashMap<java.lang.String,java.lang.String> pPrefixReplacementMap)
Sets property prefixReplacementMap.
|
void |
setReplaceWithTypePrefixes(java.lang.String[] pReplaceWithTypePrefixes)
Sets property replaceWithTypePrefixes.
|
void |
setSeparator(char pSeparator)
Sets property mSeparator.
|
void |
setSiteIDsToIndex(java.lang.String[] pSiteIDsToIndex)
Sets property siteIDsToIndex.
|
void |
setSiteRepositoryToQueryOverride(Repository pSiteRepositoryToQueryOverride)
Sets property siteRepositoryToQueryOverride.
|
void |
setSourcePropertyNameToOutputProperties(java.util.Map<java.lang.String,java.util.List<atg.repository.search.indexing.specifier.OutputProperty>> pSourcePropertyNameToOutputProperties)
Sets property sourcePropertyNameToOutputProperties.
|
void |
setSourcePropertyPathToOutputProperty(java.util.Map<java.lang.String,atg.repository.search.indexing.specifier.OutputProperty> pSourcePropertyPathToOutputProperty)
Sets property sourcePropertyPathToOutputProperty.
|
void |
setSuffixReplacementMap(java.util.LinkedHashMap<java.lang.String,java.lang.String> pSuffixReplacementMap)
Sets property suffixReplacementMap.
|
void |
setTestRecordId(java.lang.String pId) |
void |
setUseAtgSearchXmlFormat(boolean pUseAtgSearchXmlFormat)
Sets property useAtgSearchXmlFormat.
|
void |
setUsePartialExportForBaselines(boolean value)
Get the usePartialExportForBaselines value.
|
void |
setWideRecordEnabled(boolean value)
Gets the wideRecordEnabled value.
|
boolean |
shouldIncludeItem(Context pContext,
atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier,
RepositoryItem pItem)
Whether the specific repository item should be included in the index.
|
protected java.lang.String[] |
stringArrayReplaceString(java.lang.String[] pArray,
java.lang.String pMatch,
java.lang.String pReplace)
A simple utility to replace a string in a string array.
|
protected boolean |
stringListContainsName(java.lang.String[] pList,
java.lang.String pName) |
boolean |
usePartialExportForBaselines()
This method is called before running a baseline update to determine
whether a bulk or incremental export should be performed.
|
addBasicFilters, addBasicFormatters, addBasicPropertyAccessors, addDocumentLevelSpecifiers, addIfNotPresent, addValidationMessage, allowPeriodicIndexing, beforeSessionEnd, buildUriForRepositoryItem, bulkLoad, bulkLoad, bulkLoad, bulkLoad, bulkLoadForDiagnostics, bulkLoadWithRetry, bulkLoadWithRetry, calculateOutputPropertyNames, calculateRepositoryBulkLoadPropertyNames, calculateRepositorySubItemBulkLoadPropertyNames, cancelBulkLoad, cancelIncrementalUpdate, clearIterationState, containsString, correctRepositoryPath, createInitialIncrementalQueues, determineLogicalPartitionName, doStopService, executeSynchronizationsOnly, executeTestDocumentGeneration, exportAsRemoteService, generateTestDocument, getAdditionalReferencedItemDescriptors, getAdditionalReferencedItemDescriptorsSet, getAllOutputItemSpecifiers, getAllOutputProperties, getAllOutputPropertyNames, getAnalyzer, getBulkLoader, getBulkLoadQuery, getBulkLoadWithRetryMinutes, getBulkSchedule, getBulkScheduleConsiderIndexedMinutes, getBulkScheduler, getConfigRepositoryItemChangedProcessor, getContributingItemDescriptors, getDBStatTriggerItemCount, getDBStatTriggerItemName, getDBStatTriggerItemQueryCount, getDefaultFormatter, getDefaultPropertyAccessor, getDefaultPropertyAccessorPath, getDefinitionFile, getDocumentIdGenerator, getDocumentLevelSpecifiers, getDocumentSubmitter, getFilterMap, getForceIncrementalIndexingFromGeneration, getFormatterMap, getHashOutputProps, getIncrementalLoader, getIncrementalUpdateSeconds, getIndexingHashOutputProperties, getIndexingSynchronizations, getItemDescriptors, getItemDescriptors, getIterationProducer, getJobDescription, getJobName, getManualIndexRequests, getMaxFailuresAllowedForCommitting, getMaxIncrementalChanges, getMaxIncrementalChangesPerGeneration, getMaxIndexedItems, getMaxNumberProcessItemThreads, getMetaOutputPropertyNames, getMinDocumentsForBulkCommitting, getMonitoredItemDescriptorProperties, getMonitoredRepositories, getNonVersionRepositoryPath, getOutputItemSpecifier, getOutputProperties, getOutputProperties, getPrimaryRepositoryComponentPath, getProcessingPropertiesCallbacks, getPropertyAccessorMap, getPropertyAccessorToOutputPropertySet, getRepositories, getRepository, getRepositoryAdditionalBulkLoadPropertyNames, getRepositoryBulkLoadPropertyNames, getRepositoryItemGroup, getRepositorySubItemBulkLoadPropertyNames, getResourceBundleName, getRmiServer, getSchedule, getScheduler, getShadowRepositoryMap, getSiteIndexInfoService, getSpecifierModifier, getStaticOutputItemSpecifier, getSynchronizedRepositories, getTargetName, getTextActiveZones, getTextOutputPropertyNames, getThreadedItemQueueBatchSize, getThreadMethod, getTopLevelItemRepository, getUnversionedRepositoryPath, getUnversionedVersionedRepositoryPaths, getUriForRepositoryItem, getValidationMessages, getVariantProducers, getVersionedRepositoryPath, getVersionRepositoryPath, haveNestedDocumentLevelSpecifiers, haveNestedDocumentLevelSpecifiers, incrementallyLoad, indexedItem, initializeAnalyzer, initializeIndexInfo, isAutoCreateInitialQueues, isDisableSiteContextFiltering, isEnableIncrementalLoading, isEnableRepositoryPropertyBulkLoading, isEnableScheduledBulkLoading, isFilterOutDollarOutputPropertyNames, isForceDeleteGenerations, isMonitorShadowRepositories, isNonVersionRepository, isOnPubServer, isPeriodicActivityUpdateThreadRunning, isTransactional, isUseConfigurationClaims, isUseRuleInRangeQuery, isUseThreadedIndexRequestQueue, isUseThreadedItemQueue, isVersionRepository, jaxbParseFile, modifyOutputItemSpecifier, notifyIndexingInitialization, notifyIndexingTermination, performAction, performScheduledTask, postIndexingCleanup, processQueuedIncrementalUpdates, processQueuedIncrementalUpdates, processQueuedIncrementalUpdates, resolveComponents, setAdditionalReferencedItemDescriptors, setAutoCreateInitialQueues, setBulkLoader, setBulkLoadWithRetryMinutes, setBulkSchedule, setBulkScheduleConsiderIndexedMinutes, setBulkScheduler, setConfigRepositoryItemChangedProcessor, setDBStatTriggerItemCount, setDBStatTriggerItemName, setDefaultFormatter, setDefaultPropertyAccessor, setDefaultPropertyAccessorPath, setDefinitionFile, setDisableSiteContextFiltering, setDocumentIdGenerator, setDocumentLevelOutputProperties, setDocumentSubmitter, setEnableIncrementalLoading, setEnableRepositoryPropertyBulkLoading, setEnableScheduledBulkLoading, setEveryItemOutputProperties, setFilterMap, setFilterOutDollarOutputPropertyNames, setForceDeleteGenerations, setForceIncrementalIndexingFromGeneration, setFormatterMap, setIncrementalLoader, setIncrementalUpdateSeconds, setIndexingSynchronizations, setIterationProducer, setJobDescription, setJobName, setManualIndexRequests, setMaxFailuresAllowedForCommitting, setMaxIncrementalChanges, setMaxIncrementalChangesPerGeneration, setMaxIndexedItems, setMaxNumberProcessItemThreads, setMinDocumentsForBulkCommitting, setMonitorShadowRepositories, setOnPubServer, setProcessingPropertiesCallbacks, setPropertyAccessorMap, setRepository, setRepositoryAdditionalBulkLoadPropertyNames, setRepositoryItemGroup, setResourceBundleName, setRmiServer, setSchedule, setScheduler, setSiteIndexInfoService, setSpecifierModifier, setSynchronizedRepositories, setTargetName, setThreadedItemQueueBatchSize, setThreadMethod, setTransactional, setUnversionedRepositoryPath, setupContextForNewDocument, setUseConfigurationClaims, setUseRuleInRangeQuery, setUseThreadedIndexRequestQueue, setVariantProducers, setVersionedRepositoryPath, shouldCommitSession, shouldOutputDocument, startScheduledJob, stopPeriodicActivityUpdateThread, stopScheduledJob, superStartScheduledJob, unwrapVersionRepository, updateOutputItemSpecifier, validateConfiguration, warnIfMisconfiguredForSearchAdmin, warnIfMisconfiguredForSearchAdminaddLogListener, clearAbsoluteNameAndContext, getAbsoluteName, getAdminServlet, getAdminServletOutputStreamEncoding, getLoggingForVlogging, getLogListenerCount, getLogListeners, getName, getNameContext, getNucleus, getRef, getRoot, getServiceConfiguration, getServiceInfo, isAdminServletUseServletOutputStream, isLoggingDebug, isLoggingError, isLoggingInfo, isLoggingTrace, isLoggingWarning, isRunning, isStartServiceComplete, logDebug, logDebug, logDebug, logError, logError, logError, logInfo, logInfo, logInfo, logTrace, logTrace, logTrace, logWarning, logWarning, logWarning, nameContextElementBound, nameContextElementUnbound, removeLogListener, reResolveThis, resolveName, resolveName, resolveName, resolveName, sendLogEvent, setAdminServletOutputStreamEncoding, setAdminServletUseServletOutputStream, setLoggingDebug, setLoggingError, setLoggingInfo, setLoggingTrace, setLoggingWarning, setNucleus, setServiceInfo, startService, stopService, toStringvlogDebug, vlogDebug, vlogDebug, vlogDebug, vlogError, vlogError, vlogError, vlogError, vlogInfo, vlogInfo, vlogInfo, vlogInfo, vlogTrace, vlogTrace, vlogTrace, vlogTrace, vlogWarning, vlogWarning, vlogWarning, vlogWarningclone, exportObject, exportObject, exportObject, unexportObjectfinalize, getClass, notify, notifyAll, wait, wait, waitisNeededForBaseline, isNeededForBaselineFullExportpublic static java.lang.String CLASS_VERSION
public static java.lang.String CONTEXT_STATUS_REPORTER
public static java.lang.String[] ENDECA_REQUIRED_DOCUMENT_OUTPUT_PROPERTIES
public static java.lang.String[] ENDECA_REQUIRED_EVERY_ITEM_OUTPUT_PROPERTIES
protected java.util.Set<atg.repository.search.indexing.specifier.OutputProperty> mSetOutputProperties
public EndecaIndexingOutputConfig()
throws java.rmi.RemoteException
EndecaPropertyFormatterjava.rmi.RemoteExceptionpublic void setUseAtgSearchXmlFormat(boolean pUseAtgSearchXmlFormat)
RecordSubmitter the textual
output is ignored, and a Records *
instance is used instead.public boolean isUseAtgSearchXmlFormat()
RecordSubmitter the textual
output is ignored, and a Records *
instance is used instead.public void setAlwaysGenerateXml(boolean pAlwaysGenerateXml)
public boolean isAlwaysGenerateXml()
public void setAddDefaultOutputNameReplacements(boolean pAddDefaultOutputNameReplacements)
public boolean isAddDefaultOutputNameReplacements()
public void setReplaceWithTypePrefixes(java.lang.String[] pReplaceWithTypePrefixes)
public java.lang.String[] getReplaceWithTypePrefixes()
public void setNameTopLevelTypePrefixesByFirstPropertyOwner(boolean pNameTopLevelTypePrefixesByFirstPropertyOwner)
public boolean isNameTopLevelTypePrefixesByFirstPropertyOwner()
public void setPrefixReplacementMap(java.util.LinkedHashMap<java.lang.String,java.lang.String> pPrefixReplacementMap)
public java.util.LinkedHashMap<java.lang.String,java.lang.String> getPrefixReplacementMap()
public void setSuffixReplacementMap(java.util.LinkedHashMap<java.lang.String,java.lang.String> pSuffixReplacementMap)
public java.util.LinkedHashMap<java.lang.String,java.lang.String> getSuffixReplacementMap()
public java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,atg.endeca.index.PropertyTransformationRecord> getOutputPropertyToTransformations()
public void setOutputPropertyToTransformations(java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,atg.endeca.index.PropertyTransformationRecord> pOutputPropertyToTransformations)
public void setDisallowedRequiredFlags(java.lang.String[] pDisallowedRequiredFlags)
public java.lang.String[] getDisallowedRequiredFlags()
public void setLoggingDebugPropertyMerging(boolean pLoggingDebugPropertyMerging)
public boolean isLoggingDebugPropertyMerging()
public void setIdOutputPropertyName(java.lang.String pIdOutputPropertyName)
public java.lang.String getIdOutputPropertyName()
public java.util.Set<atg.repository.search.indexing.specifier.OutputProperty> getSetOutputProperties()
public void setSiteIDsToIndex(java.lang.String[] pSiteIDsToIndex)
public java.lang.String[] getSiteIDsToIndex()
public void setIndexingApplicationConfiguration(atg.endeca.index.configuration.IndexingApplicationConfiguration pIndexingApplicationConfiguration)
@NotNull public atg.endeca.index.configuration.IndexingApplicationConfiguration getIndexingApplicationConfiguration()
public java.util.Locale[] getLocales()
public boolean getMultiLanguageSynonyms()
public boolean isGenerateMultiLanguageSynonyms()
public void setGenerateMultiLanguageSynonyms(boolean pGenerateMultiLanguageSynonyms)
pGenerateMultiLanguageSynonyms - new generateMultiLanguageSynonyms valuepublic void setSeparator(char pSeparator)
public char getSeparator()
public void setExcludedItemsAncestorIds(java.lang.String[] pExcludedItemsAncestorIds)
public java.lang.String[] getExcludedItemsAncestorIds()
public void setAncestorsPropertiesMap(java.util.Map<java.lang.String,java.lang.String> pAncestorsPropertiesMap)
public java.util.Map<java.lang.String,java.lang.String> getAncestorsPropertiesMap()
public void setSiteRepositoryToQueryOverride(Repository pSiteRepositoryToQueryOverride)
public Repository getSiteRepositoryToQueryOverride()
public Repository getSiteRepositoryToQuery()
public RepositoryItem[] getSitesToIndex() throws RepositoryException
RepositoryExceptionpublic java.util.Map<java.lang.String,atg.repository.search.indexing.specifier.OutputProperty> getSourcePropertyPathToOutputProperty()
public void setSourcePropertyPathToOutputProperty(java.util.Map<java.lang.String,atg.repository.search.indexing.specifier.OutputProperty> pSourcePropertyPathToOutputProperty)
public void setOutputNameToOutputProperty(java.util.Map<java.lang.String,atg.repository.search.indexing.specifier.OutputProperty> pOutputNameToOutputProperty)
public java.util.Map<java.lang.String,atg.repository.search.indexing.specifier.OutputProperty> getOutputNameToOutputProperty()
public void setSourcePropertyNameToOutputProperties(java.util.Map<java.lang.String,java.util.List<atg.repository.search.indexing.specifier.OutputProperty>> pSourcePropertyNameToOutputProperties)
public java.util.Map<java.lang.String,java.util.List<atg.repository.search.indexing.specifier.OutputProperty>> getSourcePropertyNameToOutputProperties()
public boolean isForceToBaselineOnChange()
public void setForceToBaselineOnChange(boolean pForceToBaselineOnChange)
public void setUsePartialExportForBaselines(boolean value)
public boolean isUsePartialExportForBaselines()
public atg.endeca.index.enforcer.BaselineEnforcer[] getBaselineEnforcers()
public void setBaselineEnforcers(atg.endeca.index.enforcer.BaselineEnforcer[] baselineEnforcers)
public atg.endeca.index.enforcer.FullExportEnforcer[] getFullExportEnforcers()
public void setFullExportEnforcers(atg.endeca.index.enforcer.FullExportEnforcer[] pFullExportEnforcers)
public void setAlwaysFlushRecordStore(boolean value)
value - the new alwaysFlushRecordStore valuepublic boolean isAlwaysFlushRecordStore()
public void setWideRecordEnabled(boolean value)
value - the new wideRecordEnabled valuepublic boolean isWideRecordEnabled()
protected atg.repository.search.indexing.specifier.OutputItemSpecifier createOutputItemSpecifier()
createOutputItemSpecifier in class IndexingOutputConfigprotected atg.repository.search.indexing.specifier.OutputItemSpecifier prepareOutputItemSpecifier(atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier,
java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,atg.endeca.index.PropertyTransformationRecord> pOutputPropertyToTransformations)
pSpecifier - the static output item specifierpOutputPropertyToTransformations - the map holding
any transformation records.public void calculateOutputPropertyNames()
IndexingOutputConfigcalculateOutputPropertyNames in class IndexingOutputConfigprotected void createEmptyTransformationRecords(boolean pMeta,
atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier)
protected void createEmptyTransformationRecords(boolean pMeta,
atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier,
java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,atg.endeca.index.PropertyTransformationRecord> pTransMap)
protected void mungeAllOutputPropertyNames()
protected void mungeAllOutputPropertyNames(atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier,
java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,atg.endeca.index.PropertyTransformationRecord> pOutputPropertyToTransformations)
public atg.endeca.index.PropertyTransformationRecord getTransformationRecord(atg.repository.search.indexing.specifier.OutputProperty pProperty)
pProperty - the property whose record to fetch.public void doStartService()
throws ServiceException
IndexingOutputConfigdoStartService in class IndexingOutputConfigServiceException - if the Service had a problem starting upprotected void calculateSourcePropertyPathToOutputProperty()
protected void calculateOutputNameToOutputProperty()
protected void calculateSourcePropertyNameToOutputProperties()
protected void addDefaultOutputNameReplacements()
public atg.repository.search.indexing.LoaderResults performPartialUpdate(IndexingTask pTask) throws IndexingException
IndexableperformPartialUpdate in interface IndexablepTask - the indexing task invoking the update. May be null
if called via another means.IndexingExceptionpublic atg.repository.search.indexing.LoaderResults processQueuedIncrementalUpdates(atg.search.index.IndexInfo pIndexInfo,
atg.repository.search.indexing.DocumentSubmitterSession pSession)
throws IndexingException
IndexingExceptionpublic java.lang.String[] getDocumentLevelOutputProperties()
getDocumentLevelOutputProperties in class IndexingOutputConfigpublic java.lang.String[] getEveryItemOutputProperties()
getEveryItemOutputProperties in class IndexingOutputConfigprotected java.lang.String[] stringArrayReplaceString(java.lang.String[] pArray,
java.lang.String pMatch,
java.lang.String pReplace)
protected java.lang.String[] addInStrings(java.lang.String[] pStrings,
java.lang.String[] pRequiredStrings)
addInStrings in class IndexingOutputConfigpStrings - the source strings.pRequiredStrings - the strings to add if they aren't already
in the list.protected boolean isRequiredFlagDisallowed(java.lang.String pFlag)
protected boolean stringListContainsName(java.lang.String[] pList,
java.lang.String pName)
protected void mergeDuplicateProperties(atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier,
java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,atg.endeca.index.PropertyTransformationRecord> pOutputPropertyToTransformations)
public java.util.List<atg.repository.search.indexing.specifier.OutputProperty> getOutputPropertiesAccessible(boolean pMeta,
atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier)
public java.util.List<atg.repository.search.indexing.specifier.OutputProperty> getOutputPropertiesAccessible(boolean pMeta)
public boolean shouldIncludeItem(Context pContext, atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier, RepositoryItem pItem)
IndexingOutputConfigshouldIncludeItem in class IndexingOutputConfigpContext - the indexing context object.pSpecifier - the specifier for this item.public atg.repository.search.indexing.BulkLoaderResults performBaselineUpdate(IndexingTask pTask) throws IndexingException
IndexableperformBaselineUpdate in interface IndexablepTask - the indexing task invoking the update. May be null
if called via another means.IndexingExceptionpublic boolean isNeededForIncremental()
IndexableisNeededForIncremental in interface Indexablepublic boolean mayNeedCleanup()
IndexablemayNeedCleanup in interface Indexablepublic void postIndexingCleanup(IndexingTask pTask, boolean pSuccess, atg.repository.search.indexing.LoaderResults pResults) throws IndexingException
IndexablepostIndexingCleanup in interface IndexablepTask - the current indexing task, if any.pSuccess - true if we are cleaning up from a successful index,
false otherwise.pResults - the loader results (if any) returns from
performBaselineUpdate and performPartialUpdate.IndexingException@Deprecated public boolean cancel(IndexingTask pTask, boolean pBaseline) throws IndexingException
cancel in interface IndexablepBaseline - true if this is a baseline/full index, false if
this is an incremental/partial index.IndexingExceptionpublic boolean cancel(IndexingTask pTask) throws IndexingException
cancel in interface IndexableIndexingExceptionpublic void afterSessionStart(Context pContext) throws IndexingException
IndexingOutputConfigafterSessionStart in interface atg.repository.search.indexing.IndexingSynchronizationafterSessionStart in class IndexingOutputConfigpContext - the Context for the current indexing operation. The
DocumentSubmitterSession is available as a property, as is
the IndexingOutputConfig and other state information.IndexingExceptionpublic boolean isSupportsStatusCounts()
IndexableisSupportsStatusCounts in interface Indexablepublic java.util.Set<java.lang.String> getIndexingOutputConfigPaths()
getIndexingOutputConfigPaths in interface Indexablepublic boolean isForceToBaseline()
isForceToBaseline in interface Indexabletrue if the job should be forced to baseline.public boolean isForceToBaselineFullExport(IndexingJob pJob)
isForceToBaselineFullExport in interface Indexabletrue if the job should be forced to full export.public atg.repository.search.indexing.BulkLoaderResults performBaselineFullExportUpdate(IndexingTask pTask) throws IndexingException
IndexableThis is called "performBulkLoad" rather than "bulkLoad" so that MultiConfigLoader could implement it.
performBaselineFullExportUpdate in interface IndexablepTask - the indexing task invoking the update. May be null
if called via another means.IndexingExceptionpublic boolean usePartialExportForBaselines()
IndexableusePartialExportForBaselines in interface Indexablepublic boolean isForceToBaseline(IndexingJob pJob)
isForceToBaseline in interface atg.endeca.index.ExtendedIndexablepublic void persistInitialState(java.util.Map<java.lang.String,java.lang.Object> pBaselineState,
java.util.Map<java.lang.String,java.lang.Object> pFullExportState)
persistInitialState in interface Indexablepublic boolean alwaysFlushRecordStore()
alwaysFlushRecordStore in interface Indexableprotected atg.search.index.IndexInfo createDefaultIndexInfo()
createDefaultIndexInfo in class IndexingOutputConfigpublic atg.search.index.IndexInfo createTestIndexInfo()
throws IndexingException
IndexingOutputConfigcreateTestIndexInfo in class IndexingOutputConfigIndexingExceptionprotected javax.servlet.Servlet createAdminServlet()
GenericRMIServicecreateAdminServlet in class IndexingOutputConfigpublic Context createTestContext() throws IndexingException
IndexingExceptionpublic java.lang.String getTestRecordId()
public void setTestRecordId(java.lang.String pId)
throws IndexingException
IndexingExceptionpublic java.util.List<Record> generateTestRecords(java.lang.String pId) throws IndexingException
IndexingExceptionpublic java.lang.String[] getRequiredDocumentOutputProperties()
IndexingOutputConfiggetRequiredDocumentOutputProperties in class IndexingOutputConfigpublic java.lang.String[] getRequiredEveryItemOutputProperties()
IndexingOutputConfiggetRequiredEveryItemOutputProperties in class IndexingOutputConfig