|
EAC Components 3.2.2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object com.endeca.soleng.eac.toolkit.base.EacElement com.endeca.soleng.eac.toolkit.base.Provisionable com.endeca.soleng.eac.toolkit.component.CustomComponent com.endeca.soleng.eac.toolkit.component.ContentAcquisitionServerComponent
public class ContentAcquisitionServerComponent
This custom component represents a Content Acquisition System Server. It exposes methods for executing CAS crawls using the CAS Server. Crawls must be configured externally, and this component does not provide utilities for provisioning new crawls and changing the configuration of an existing crawl. Execution of commands against a non-existent crawl will fail with an exception. It is expected that developers will use an external tool or the CAS console to create and manage configuration of crawls. Though this is "provisioned" like a component in the app configuration, this object's provisioning is stored as a set of custom properties (key value pairs) on the provisioned host on which this component runs.
Field Summary |
---|
Fields inherited from class com.endeca.soleng.eac.toolkit.base.EacElement |
---|
appName, dataPrefix, eacHost, eacPort, elementId, lockManager, logDir, sslEnabled, workingDir |
Constructor Summary | |
---|---|
ContentAcquisitionServerComponent()
Constructor for the Config Manager custom component. |
Method Summary | |
---|---|
void |
checkCasVersion()
This method checks the version of the CAS server (as reported by a service call to the CAS web service) against the expected version defined when this class was built. |
void |
cleanOutputDir(java.lang.String crawlName)
Cleans the crawl's output directory (specified in the crawl configuration, usually through the CAS Console), removing any files in that directory that match the naming convention used by this component. |
void |
clearCrawlOutputFromDir(java.lang.String crawlName,
boolean isIncrementalCrawl,
java.lang.String hostId,
java.lang.String targetDir)
Deletes files associated with the specified crawl from the specified directory. |
void |
clearFullCrawlOutputFromDestinationDir(java.lang.String crawlName)
Convenience method to invoke clearCrawlOutputFromDestinationDir method with the isIncrementalCrawl argument set to false. |
void |
clearIncrementalCrawlOutputFromDestinationDir(java.lang.String crawlName)
Convenience method to invoke clearCrawlOutputFromDestinationDir method with the isIncrementalCrawl argument set to true. |
void |
copyBaselineCrawlOutputToDestinationDir(java.lang.String crawlName)
Convenience method to invoke copyCrawlOutputToDestinationDir method with the isIncrementalCrawl argument set to false. |
void |
copyCrawlOutputToDestinationDir(java.lang.String crawlName,
boolean isIncrementalCrawl)
This method is expected to be used in conjunction with the renameCrawlOutput method, as it assumes the naming convention created by that method. |
void |
copyIncrementalCrawlOutputToDestinationDir(java.lang.String crawlName)
Convenience method to invoke copyCrawlOutputToDestinationDir method with the isIncrementalCrawl argument set to true. |
java.lang.String |
getCasCrawlFullOutputDestDir()
|
java.lang.String |
getCasCrawlIncrementalOutputDestDir()
|
java.lang.String |
getCasCrawlOutputDestHost()
|
java.lang.String |
getCasHost()
|
java.lang.String |
getCasPort()
|
java.lang.String |
getCrawlOutputDir(java.lang.String crawlName)
Queries the CAS to retrieve the crawl output directory from the crawl config. |
java.lang.String |
getCrawlOutputPrefix(java.lang.String crawlName)
Queries the CAS to retrieve the crawl output file prefix from the crawl config. |
java.lang.String |
getCrawlOutputSuffix(java.lang.String crawlName)
Queries the CAS to retrieve the crawl output file suffix from the crawl config. |
com.endeca.itl.cas.CrawlerState |
getCrawlStatus(java.lang.String crawlName)
Retrieves the status of the specified crawl. |
long |
getLongPropertyValueOrDefault(java.lang.String propName,
long defaultValue)
|
long |
getMaxMissedStatusChecksAllowed()
|
long |
getMaxWaitTimeSeconds()
|
long |
getMinWaitTimeSeconds()
|
int |
getNumMissedStatusChecks()
|
long |
getSlowPollingIntervalMs()
|
long |
getStandardPollingIntervalMs()
|
void |
incrementMissedStatusQueries()
|
boolean |
isCrawlActive(java.lang.String crawlName)
Test whether the crawl is active (running or stopping). |
boolean |
isCrawlDefined(java.lang.String crawlName)
Requests a list of crawls defined in the CAS and returns true if one of them matches the specified crawl name. |
boolean |
isCrawlFileOutput(java.lang.String crawlName)
Checks if the crawl output type is File System |
boolean |
isCrawlRunning(java.lang.String crawlName)
Test whether the crawl is running. |
boolean |
isCrawlStopped(java.lang.String crawlName)
Test whether the crawl is stopped. |
boolean |
isCrawlStopping(java.lang.String crawlName)
Test whether the crawl is stopping. |
java.util.List<java.lang.String> |
listCasCrawls()
Returns a list of the crawls defined in the CAS. |
void |
renameBaselineCrawlOutput(java.lang.String crawlName)
Convenience method to invoke renameCrawlOutput method with the isIncrementalCrawl argument set to false. |
void |
renameCrawlOutput(java.lang.String crawlName,
boolean isIncrementalCrawl)
Renames the crawl output file for a specified crawl to include the crawl name as a prefix as well as a timestamp if it's an incremental crawl. |
void |
renameIncrementalCrawlOutput(java.lang.String crawlName)
Convenience method to invoke renameCrawlOutput method with the isIncrementalCrawl argument set to true. |
void |
runBaselineCasCrawl(java.lang.String crawlName)
Runs to completion a full crawl of the CAS crawl with the specified name. |
void |
runIncrementalCasCrawl(java.lang.String crawlName)
Runs to completion an incremental crawl of the CAS crawl with the specified name. |
void |
setDefinition()
|
void |
setNumMissedStatusChecks(int numMissedStatusQueries)
|
void |
startBaselineCasCrawl(java.lang.String crawlName)
Executes a baseline crawl for the specified crawl name. |
void |
startIncrementalCasCrawl(java.lang.String crawlName)
Executes an incremental crawl for the specified crawl name. |
boolean |
waitForFinished(java.lang.String crawlName)
Waits for the specified crawl to finish (to be in a non-active state) or for the maximum amount of wait time to elapse. |
Methods inherited from class com.endeca.soleng.eac.toolkit.component.CustomComponent |
---|
buildEacStub, getCustomDirectories, getHost, getHostId, getProperties, getProperty, isDefined, isDefinitionChanged, removeDefinition, setCustomDirectories, setHostId, setProperties, updateDefinition |
Methods inherited from class com.endeca.soleng.eac.toolkit.base.Provisionable |
---|
getAppDefinitionFromEac, getCachedAppDefinition, getProvisioningPort, invalidateCachedAppDefinition, setCachedAppDefinition |
Methods inherited from class com.endeca.soleng.eac.toolkit.base.EacElement |
---|
getAppName, getDataPrefix, getEacHost, getEacPort, getElementId, getLockManager, getLogDir, getWorkingDir, isSslEnabled, setAppName, setDataPrefix, setEacHost, setEacPort, setElementId, setLockManager, setLogDir, setSslEnabled, setWorkingDir |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ContentAcquisitionServerComponent()
Method Detail |
---|
public void cleanOutputDir(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException, com.endeca.soleng.eac.toolkit.exception.AppConfigurationException, com.endeca.soleng.eac.toolkit.exception.EacCommunicationException, com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
crawlName
- Crawl whose output directory should be cleaned.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
public void setDefinition() throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
setDefinition
in class com.endeca.soleng.eac.toolkit.component.CustomComponent
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
public boolean isCrawlDefined(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Crawl to test.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public java.util.List<java.lang.String> listCasCrawls() throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public void runBaselineCasCrawl(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException, com.endeca.soleng.eac.toolkit.exception.CasControlException
crawlName
- Name of the crawl to run.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
com.endeca.soleng.eac.toolkit.exception.CasControlException
public void runIncrementalCasCrawl(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException, com.endeca.soleng.eac.toolkit.exception.CasControlException
crawlName
- Name of the crawl to run.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
com.endeca.soleng.eac.toolkit.exception.CasControlException
public boolean waitForFinished(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Name of the crawl to poll for status.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public void startBaselineCasCrawl(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Name of the crawl to execute.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public void startIncrementalCasCrawl(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Name of the crawl to execute.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public com.endeca.itl.cas.CrawlerState getCrawlStatus(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Name of the crawl to query.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public boolean isCrawlActive(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Crawl to test.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public boolean isCrawlFileOutput(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
-
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public boolean isCrawlRunning(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Crawl to test.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public boolean isCrawlStopping(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Crawl to test.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public boolean isCrawlStopped(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Crawl to test.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public void clearIncrementalCrawlOutputFromDestinationDir(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException, com.endeca.soleng.eac.toolkit.exception.AppConfigurationException, com.endeca.soleng.eac.toolkit.exception.EacCommunicationException, com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
public void clearFullCrawlOutputFromDestinationDir(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException, com.endeca.soleng.eac.toolkit.exception.AppConfigurationException, com.endeca.soleng.eac.toolkit.exception.EacCommunicationException, com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
public void clearCrawlOutputFromDir(java.lang.String crawlName, boolean isIncrementalCrawl, java.lang.String hostId, java.lang.String targetDir) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException, com.endeca.soleng.eac.toolkit.exception.AppConfigurationException, com.endeca.soleng.eac.toolkit.exception.EacCommunicationException, com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
crawlName
- Name of the crawl whose output files are to be removed.isIncrementalCrawl
- True if files are to be deleted for an incremental crawl.hostId
- ID of host on which directory to be cleaned resides.targetDir
- Directory from which target files should be removed.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
public void copyIncrementalCrawlOutputToDestinationDir(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException, com.endeca.soleng.eac.toolkit.exception.EacCommunicationException, com.endeca.soleng.eac.toolkit.exception.EacComponentControlException, com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public void copyBaselineCrawlOutputToDestinationDir(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException, com.endeca.soleng.eac.toolkit.exception.EacCommunicationException, com.endeca.soleng.eac.toolkit.exception.EacComponentControlException, com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public void copyCrawlOutputToDestinationDir(java.lang.String crawlName, boolean isIncrementalCrawl) throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException, com.endeca.soleng.eac.toolkit.exception.EacCommunicationException, com.endeca.soleng.eac.toolkit.exception.EacComponentControlException, com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Name of the crawl whose output is to be copied.isIncrementalCrawl
- True if the output is that of an incremental crawl.
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public void renameIncrementalCrawlOutput(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException, com.endeca.soleng.eac.toolkit.exception.EacCommunicationException, com.endeca.soleng.eac.toolkit.exception.EacComponentControlException, com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public void renameBaselineCrawlOutput(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException, com.endeca.soleng.eac.toolkit.exception.EacCommunicationException, com.endeca.soleng.eac.toolkit.exception.EacComponentControlException, com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public void renameCrawlOutput(java.lang.String crawlName, boolean isIncrementalCrawl) throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException, com.endeca.soleng.eac.toolkit.exception.EacCommunicationException, com.endeca.soleng.eac.toolkit.exception.EacComponentControlException, com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Name of the crawl whose output is to be renamed.isIncrementalCrawl
- True if an incremental crawl's output is to be renamed.
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public java.lang.String getCrawlOutputDir(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Name of the crawl to be queried.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public java.lang.String getCrawlOutputPrefix(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Name of the crawl to be queried.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public java.lang.String getCrawlOutputSuffix(java.lang.String crawlName) throws com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
crawlName
- Name of the crawl to be queried.
com.endeca.soleng.eac.toolkit.exception.CasCommunicationException
public void checkCasVersion()
public java.lang.String getCasPort()
public java.lang.String getCasHost()
public java.lang.String getCasCrawlFullOutputDestDir()
public java.lang.String getCasCrawlIncrementalOutputDestDir()
public java.lang.String getCasCrawlOutputDestHost()
public long getLongPropertyValueOrDefault(java.lang.String propName, long defaultValue)
public long getMaxMissedStatusChecksAllowed()
public long getStandardPollingIntervalMs()
public long getSlowPollingIntervalMs()
public long getMinWaitTimeSeconds()
public long getMaxWaitTimeSeconds()
public int getNumMissedStatusChecks()
public void setNumMissedStatusChecks(int numMissedStatusQueries)
public void incrementMissedStatusQueries()
|
EAC Components 3.2.2 | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
@VERSION PRODUCT: EAC Components (eacComponents) VERSION: 3.2.2 BUILD: NONEDEV ARCH_OS: n/a DATE: 2012-02-28T13:13:23-0500