atg.endeca.index
Class RecordStoreBulkLoaderImpl

java.lang.Object
  extended by atg.nucleus.logging.VariableArgumentApplicationLoggingImpl
      extended by atg.nucleus.GenericService
          extended by atg.repository.search.indexing.LoaderImpl
              extended by atg.repository.search.indexing.BulkLoaderImpl
                  extended by atg.endeca.index.RecordStoreBulkLoaderImpl
All Implemented Interfaces:
atg.naming.AbsoluteNameable, NameContextBindingListener, NameContextElement, atg.naming.NameContextParentable, NameResolver, AdminableService, atg.nucleus.Configured, ApplicationLogging, atg.nucleus.logging.ApplicationLoggingSender, atg.nucleus.logging.TraceApplicationLogging, VariableArgumentApplicationLogging, ComponentNameResolver, Service, ServiceListener, atg.repository.search.indexing.BulkLoader, java.util.EventListener

public class RecordStoreBulkLoaderImpl
extends atg.repository.search.indexing.BulkLoaderImpl

A BulkLoader subclass that adds support for creating a RecordStoreOutputDocumentContent, as well as adding support for ProcessingPropertiesCallback and PerDocumentIndexingSynchronization.

Created: November 04 2011


Field Summary
static java.lang.String CLASS_VERSION
          Class version string from source code control system.
 
Fields inherited from class atg.repository.search.indexing.BulkLoaderImpl
EMPTY_REPOSITORY_ARRAY
 
Fields inherited from class atg.repository.search.indexing.LoaderImpl
DELETE_DOCUMENT, GET_GENERATOR_PROPERTY, GET_META_PROPERTY, GET_TEXT_PROPERTY, MY_RESOURCE_NAME, PROCESS_PROPERTIES, REGENERATE_FOR_CHANGE, sResourceBundle, START_QUERY
 
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
RecordStoreBulkLoaderImpl()
           
 
Method Summary
protected  atg.repository.search.indexing.Context createContext()
          Create a new context.
protected  atg.repository.search.indexing.OutputDocumentContent createEmptyOutputDocumentContent()
           
protected  void outputAndSubmitDocument(atg.repository.search.indexing.Context pContext)
          Create the XHTML file for the Context's OutputDocumentContent and submit it using the DocumentSubmitterSession.
protected  void processProperties(atg.repository.search.indexing.Context pContext, RepositoryItem pItem, atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier, atg.repository.search.indexing.specifier.OutputProperty[] pProperties, boolean pIsMeta, java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,java.lang.Object> pGeneratorMap)
           
protected  void releaseContext(atg.repository.search.indexing.Context pContext)
           
 
Methods inherited from class atg.repository.search.indexing.BulkLoaderImpl
anyItemOfType, assetVersionsToRepositoryItems, bulkLoad, bulkLoad, bulkLoad, bulkLoad, bulkLoadWithRetry, deleteGenerationChanges, fetchItemsUsingThreadedQueue, generateTestDocument, getDevelopmentLines, getGcCallingRangeSize, getJaxbUnmarshaller, getPagedQuery, getPagedQuery, getPagedQueryOptions, getPagedQuerySize, getRepositoryIdPropertyDescriptor, isItemOfTypeInSet, loadIteration, loadPagedIteration, postIndexingCleanup, setGcCallingRangeSize, setJaxbUnmarshaller, setPagedQuerySize, uriMapFromAssetVersions
 
Methods inherited from class atg.repository.search.indexing.LoaderImpl
addActiveContext, adjustIncrementalQueue, afterSessionStart, beforeSessionEnd, cancelActiveContext, claimGeneration, createAdminServlet, createMembershipContextSet, deleteDocumentItem, deleteOrExcludeItem, doStopService, getActiveContextStatuses, getArrayFromMultiRepoItems, getConfigStatePersister, getDocumentsPerTransaction, getIncrementalItemQueue, getLoggingInfoStatusCount, getTransactionManager, getUpdateActivityTimeMillis, getUpdateLastActivityTimeInSeparateThread, initContext, isConnectionRelated, isEchoDocumentsToStdout, isItemLoggingDebug, isPrettyPrint, isPropertyLoggingDebug, isSubTypeOfItemDesc, isTransactionPerDocument, nextQueuedUpdateActivity, popMembershipContexts, processItem, processMetaProperty, processParentProperties, processProperties, processTextProperty, pushMembershipContexts, pushMembershipContextsIfUsedByRepository, queueUpdateActivity, releaseGeneration, removeActiveContext, repositoryUsesMembershipContext, resetContextAfterDocument, setConfigStatePersister, setDocumentsPerTransaction, setEchoDocumentsToStdout, setIncrementalItemQueue, setItemLoggingDebug, setLoggingInfoStatusCount, setNextIncrementalGeneration, setPrettyPrint, setPropertyLoggingDebug, setTransactionPerDocument, setUpdateActivityTimeMillis, setUpdateLastActivityTimeInSeparateThread, splitPropertyValue, updateActivity
 
Methods inherited from class atg.nucleus.GenericService
addLogListener, doStartService, getAbsoluteName, getAdminServlet, getAdminServletOutputStreamEncoding, getLoggingForVlogging, getLogListenerCount, getLogListeners, getName, getNameContext, getNucleus, getRoot, getServiceConfiguration, getServiceInfo, isAdminServletUseServletOutputStream, isLoggingDebug, isLoggingError, isLoggingInfo, isLoggingTrace, isLoggingWarning, isRunning, 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
 
Methods inherited from class atg.nucleus.logging.VariableArgumentApplicationLoggingImpl
vlogDebug, vlogDebug, vlogDebug, vlogDebug, vlogDebugTrace, 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

CLASS_VERSION

public static final java.lang.String CLASS_VERSION
Class version string from source code control system.

See Also:
Constant Field Values
Constructor Detail

RecordStoreBulkLoaderImpl

public RecordStoreBulkLoaderImpl()
Method Detail

createEmptyOutputDocumentContent

protected atg.repository.search.indexing.OutputDocumentContent createEmptyOutputDocumentContent()
Overrides:
createEmptyOutputDocumentContent in class atg.repository.search.indexing.LoaderImpl

createContext

protected atg.repository.search.indexing.Context createContext()
Create a new context. One context is created for each update (incremental or bulk).

Overrides:
createContext in class atg.repository.search.indexing.LoaderImpl

releaseContext

protected void releaseContext(atg.repository.search.indexing.Context pContext)
Overrides:
releaseContext in class atg.repository.search.indexing.LoaderImpl

outputAndSubmitDocument

protected void outputAndSubmitDocument(atg.repository.search.indexing.Context pContext)
                                throws atg.repository.search.indexing.IndexingException
Create the XHTML file for the Context's OutputDocumentContent and submit it using the DocumentSubmitterSession.

Overrides:
outputAndSubmitDocument in class atg.repository.search.indexing.LoaderImpl
Throws:
atg.repository.search.indexing.IndexingException

processProperties

protected void processProperties(atg.repository.search.indexing.Context pContext,
                                 RepositoryItem pItem,
                                 atg.repository.search.indexing.specifier.OutputItemSpecifier pSpecifier,
                                 atg.repository.search.indexing.specifier.OutputProperty[] pProperties,
                                 boolean pIsMeta,
                                 java.util.Map<atg.repository.search.indexing.specifier.OutputProperty,java.lang.Object> pGeneratorMap)
Overrides:
processProperties in class atg.repository.search.indexing.LoaderImpl