public class DgraphCluster
extends com.endeca.soleng.eac.toolkit.base.Provisionable
| Constructor and Description |
|---|
DgraphCluster()
Default constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addDgraph(DgraphComponent dgraph)
Adds a dgraph to the group.
|
void |
applyConfigSnapshot()
Extracts the current config file from the given directory for processing.
|
void |
applyConfigSnapshot(String dgraphId)
Extracts the current config file from the given directory for processing.
|
void |
applyConfigUpdate()
Updates the configuration of dgraphs in the group.
|
void |
applyIndex()
Cycles the dgraphs in the group.
|
void |
applyPartialUpdates()
Updates the dgraphs in the group.
|
void |
cleanDirs() |
void |
cleanLocalDgraphConfigDirs() |
void |
cleanLocalIndexDirs() |
void |
cleanLocalPartialsDirs() |
void |
cleanLocalXQueryDirs() |
void |
copyCumulativePartialUpdatesToDgraphServers()
Retrieves cumulative partials for each dgraph in the group.
|
void |
copyDgraphConfigToDgraphServers()
Retrieves dgraph config for each dgraph in the group.
|
void |
copyIndexToDgraphServers()
Retrieves a new index for each dgraph in the group.
|
void |
copyPartialUpdateToDgraphServers()
Retrieves a partial update for each dgraph in the group.
|
void |
copyXQueryToDgraphServers()
Retrieves XQuery modules for each dgraph in the group.
|
void |
cycle() |
String |
getConfigSnapshotDir() |
DgraphComponent |
getDgraphById(String dgraphId)
Retrieves the Dgraph with the specified ID from the group.
|
Map<String,List<DgraphComponent>> |
getDgraphGroups(String groupProp)
Retrieves a map, whose keys are the groups defined for the application,
and whose values are lists of dgraphs belonging to each group.
|
Map<String,List<DgraphComponent>> |
getDgraphRestartGroups()
Retrieves a map, whose keys are the restart groups defined for the application,
and whose values are lists of dgraphs belonging to each restart group.
|
List<DgraphComponent> |
getDgraphs() |
List<DgraphComponent> |
getDgraphsInGroup(String groupProp,
String group)
Retrieves a list of all dgraphs belonging to the specified group.
|
List<DgraphComponent> |
getDgraphsInRestartGroup(String restartGroup)
Retrieves a list of all dgraphs belonging to the specified restart group.
|
List<String> |
getGroups(String groupProp)
Retrieves a list of all the groups with which the group's dgraphs
are associated.
|
List<String> |
getRestartGroups()
Retrieves a list of all the restart groups with which the group's dgraphs
are associated.
|
boolean |
isDefined()
Checks whether the member dgraphs in the group are defined.
|
boolean |
isDefinitionChanged()
Checks whether the member dgraphs in the group have changed.
|
boolean |
isDirectFromDgidxOutput() |
boolean |
isEnabled() |
boolean |
isGetDataInParallel() |
void |
reloadXqueryModules()
Reloads XQuery modules of dgraphs in the group.
|
void |
removeDefinition()
Removes the definition of each defined dgraph in the group.
|
String |
retrieveCurrentConfigurationSnapshot(String directoryName)
Retieves the name of the current configuration snapshot in the directory given.
|
void |
setCachedAppDefinition(com.endeca.eac.client.ApplicationType cachedAppDefinition) |
void |
setConfigSnapshotDir(String configSnapshotDir) |
void |
setDefinition()
Sets the definition of each dgraph in the group that is not already defined.
|
void |
setDgraphs(List<DgraphComponent> dgraphs) |
void |
setDirectFromDgidxOutput(boolean directFromDgidxOutput) |
void |
setEnabled(boolean enabled) |
void |
setGetDataInParallel(boolean getDataInParallel) |
void |
start() |
void |
stop() |
void |
updateDefinition()
Updates the definition of each dgraph in the group.
|
getAppDefinitionFromEac, getCachedAppDefinition, getProvisioningPort, invalidateCachedAppDefinitiongetAppName, getDataPrefix, getEacHost, getEacPort, getElementId, getLockManager, getLogDir, getWorkingDir, isSslEnabled, setAppName, setDataPrefix, setEacHost, setEacPort, setElementId, setLockManager, setLogDir, setSslEnabled, setWorkingDirpublic String retrieveCurrentConfigurationSnapshot(String directoryName) throws IOException
directoryName - The directory name containing the configuration files and current file tracker fileIOException - is thrown if there was a problem reading the file or retrieving the most
current valuepublic void cleanDirs()
throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptioncom.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptionInterruptedExceptionpublic void cleanLocalIndexDirs()
throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptioncom.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptionInterruptedExceptionpublic void cleanLocalPartialsDirs()
throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptioncom.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptionInterruptedExceptionpublic void cleanLocalDgraphConfigDirs()
throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptioncom.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptionInterruptedExceptionpublic void cleanLocalXQueryDirs()
throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptioncom.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptionInterruptedExceptionpublic void copyIndexToDgraphServers()
throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptionInterruptedExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptioncom.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptionpublic void copyPartialUpdateToDgraphServers()
throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptionInterruptedExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptioncom.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptionpublic void copyCumulativePartialUpdatesToDgraphServers()
throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptionInterruptedExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptioncom.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptionpublic void copyDgraphConfigToDgraphServers()
throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptionInterruptedExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptioncom.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptionpublic void copyXQueryToDgraphServers()
throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException,
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptionInterruptedExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptioncom.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptionpublic void start()
throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptionpublic void cycle()
throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException,
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptionInterruptedExceptioncom.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptionpublic void stop()
throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationExceptioncom.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptionpublic void applyIndex()
throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException,
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException - If a communication error occurs while
cycling a component.com.endeca.soleng.eac.toolkit.exception.EacComponentControlException - If an error occurs while trying to
cycle a component.InterruptedException - If the thread is interrupted while waiting for
a component to finish.com.endeca.soleng.eac.toolkit.exception.AppConfigurationException - If a utility fails to initialize because of
insufficient configuration information.public void applyPartialUpdates()
throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException,
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException - If a communication error occurs while
cycling a component.com.endeca.soleng.eac.toolkit.exception.EacComponentControlException - If an error occurs while trying to
cycle a component.InterruptedException - If the thread is interrupted while waiting for
a component to finish.com.endeca.soleng.eac.toolkit.exception.AppConfigurationException - If a utility fails to initialize because of
insufficient configuration information.public void applyConfigUpdate()
throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException,
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException - If a communication error occurs while
updating a component.com.endeca.soleng.eac.toolkit.exception.EacComponentControlException - If an error occurs while trying to
update a component.InterruptedException - If the thread is interrupted while waiting for
a component to finish.com.endeca.soleng.eac.toolkit.exception.AppConfigurationException - If a utility fails to initialize because of
insufficient configuration information.public void reloadXqueryModules()
throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
InterruptedException,
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.EacCommunicationException - If a communication error occurs while
updating a component.com.endeca.soleng.eac.toolkit.exception.EacComponentControlException - If an error occurs while trying to
update a component.InterruptedException - If the thread is interrupted while waiting for
a component to finish.com.endeca.soleng.eac.toolkit.exception.AppConfigurationException - If a utility fails to initialize because of
insufficient configuration information.public boolean isDefined()
throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacProvisioningException
isDefined in class com.endeca.soleng.eac.toolkit.base.Provisionablecom.endeca.soleng.eac.toolkit.exception.EacCommunicationException - If a communication error occurs while
retrieving the provisioning port.com.endeca.soleng.eac.toolkit.exception.EacProvisioningException - If an error occurs while trying to retrieve
a component definition from the EAC.public boolean isDefinitionChanged()
throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacProvisioningException
isDefinitionChanged in class com.endeca.soleng.eac.toolkit.base.Provisionablecom.endeca.soleng.eac.toolkit.exception.EacCommunicationException - If a communication error occurs while
retrieving the provisioning port.com.endeca.soleng.eac.toolkit.exception.EacProvisioningException - If an error occurs while trying to retrieve
a component definition from the EAC.public void removeDefinition()
throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException
removeDefinition in class com.endeca.soleng.eac.toolkit.base.Provisionablecom.endeca.soleng.eac.toolkit.exception.EacCommunicationException - If a communication error occurs while
retrieving the provisioning port.com.endeca.soleng.eac.toolkit.exception.EacProvisioningExceptioncom.endeca.soleng.eac.toolkit.exception.EacProvisioningException - If an error occurs while trying to retrieve
a component definition from the EAC.com.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptionpublic void setDefinition()
throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException
setDefinition in class com.endeca.soleng.eac.toolkit.base.Provisionablecom.endeca.soleng.eac.toolkit.exception.EacCommunicationException - If a communication error occurs while
retrieving the provisioning port.public void updateDefinition()
throws com.endeca.soleng.eac.toolkit.exception.EacCommunicationException,
com.endeca.soleng.eac.toolkit.exception.EacComponentControlException,
com.endeca.soleng.eac.toolkit.exception.EacProvisioningException,
com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
updateDefinition in class com.endeca.soleng.eac.toolkit.base.Provisionablecom.endeca.soleng.eac.toolkit.exception.EacCommunicationException - If a communication error occurs while
retrieving the provisioning port.com.endeca.soleng.eac.toolkit.exception.EacComponentControlExceptioncom.endeca.soleng.eac.toolkit.exception.EacProvisioningExceptioncom.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptionpublic String getConfigSnapshotDir()
public void setConfigSnapshotDir(String configSnapshotDir)
public List<DgraphComponent> getDgraphs()
public DgraphComponent getDgraphById(String dgraphId)
dgraphId - ID of the dgraph to retrieve.public Map<String,List<DgraphComponent>> getDgraphRestartGroups()
public Map<String,List<DgraphComponent>> getDgraphGroups(String groupProp)
public List<DgraphComponent> getDgraphsInRestartGroup(String restartGroup)
restartGroup - Name of the restart group whose member dgraphs should
be retrieved.public List<DgraphComponent> getDgraphsInGroup(String groupProp, String group)
groupProp - Name of the grouping property (e.g. restartGroup, updateGroup)group - Name of the group whose member dgraphs should
be retrieved.public List<String> getRestartGroups()
public List<String> getGroups(String groupProp)
groupProp - Name of the grouping property (e.g. restartGroup, updateGroup)public void setDgraphs(List<DgraphComponent> dgraphs)
public void addDgraph(DgraphComponent dgraph)
dgraph - public boolean isGetDataInParallel()
public void setGetDataInParallel(boolean getDataInParallel)
public void setDirectFromDgidxOutput(boolean directFromDgidxOutput)
public boolean isDirectFromDgidxOutput()
public boolean isEnabled()
public void setEnabled(boolean enabled)
public void setCachedAppDefinition(com.endeca.eac.client.ApplicationType cachedAppDefinition)
setCachedAppDefinition in class com.endeca.soleng.eac.toolkit.base.Provisionablepublic void applyConfigSnapshot()
throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptionpublic void applyConfigSnapshot(String dgraphId) throws com.endeca.soleng.eac.toolkit.exception.AppConfigurationException
com.endeca.soleng.eac.toolkit.exception.AppConfigurationExceptionCopyright © 2017, Oracle and/or its affiliates. All rights reserved.