atg.endeca.index
Class RecordStoreBulkLoaderImpl

java.lang.Object
  atg.nucleus.logging.VariableArgumentApplicationLoggingImpl
      atg.nucleus.GenericService
          atg.repository.search.indexing.LoaderImpl
              atg.repository.search.indexing.BulkLoaderImpl
                  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

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	releaseContext(atg.repository.search.indexing.Context pContext)

Methods inherited from class atg.repository.search.indexing.BulkLoaderImpl

anyItemOfType, assetVersionsToRepositoryItems, bulkLoad, bulkLoad, bulkLoad, bulkLoad, bulkLoadWithRetry, createTestContext, 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, 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 java.lang.String CLASS_VERSION

Class version string

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