public class CoordOldInputDependency extends Object implements CoordInputDependency
| Modifier and Type | Field and Description |
|---|---|
protected String |
missingDependencies |
INTERNAL_VERSION_ID| Constructor and Description |
|---|
CoordOldInputDependency() |
CoordOldInputDependency(String missingDependencies) |
| Modifier and Type | Method and Description |
|---|---|
void |
addInputInstanceList(String inputEventName,
List<CoordInputInstance> inputInstanceList)
Adds the input instance list.
|
void |
addToAvailableDependencies(Collection<String> availableList)
Adds the to available dependencies.
|
void |
addUnResolvedList(String name,
String unresolvedDependencies)
Adds the un resolved list.
|
void |
appendToDependencies(List<CoordInputInstance> inputInstanceList) |
boolean |
checkPullMissingDependencies(CoordinatorActionBean coordAction,
StringBuilder existList,
StringBuilder nonExistList)
Check pull missing dependencies.
|
ActionDependency |
checkPushMissingDependencies(CoordinatorActionBean coordAction,
boolean registerForNotification)
Check push missing dependencies.
|
boolean |
checkUnresolved(CoordinatorActionBean coordAction,
org.jdom.Element eAction)
Check unresolved.
|
List<String> |
getAvailableDependencies(String dataSet)
Gets the available dependencies.
|
List<String> |
getAvailableDependenciesAsList()
Gets the available dependencies as list.
|
String |
getMissingDependencies()
Gets the missing dependencies.
|
List<String> |
getMissingDependenciesAsList()
Gets the missing dependencies as list.
|
boolean |
isChangeInDependency(StringBuilder nonExistList,
String missingDependencies,
StringBuilder nonResolvedList,
boolean status)
Checks if is change in dependency.
|
boolean |
isDependencyMet()
Checks if dependencies are meet.
|
boolean |
isUnResolvedDependencyMet()
Checks if is unresolved dependencies met.
|
boolean |
pathExists(CoordinatorActionBean coordAction,
String sPath,
org.apache.hadoop.conf.Configuration actionConf,
String user) |
String |
serialize()
Serialize.
|
void |
setDependencyMet(boolean isDependencyMeet)
Sets the dependency meet.
|
void |
setMissingDependencies(String missingDependencies)
Sets the missing dependencies.
|
protected transient String missingDependencies
public CoordOldInputDependency(String missingDependencies)
public CoordOldInputDependency()
public void addInputInstanceList(String inputEventName, List<CoordInputInstance> inputInstanceList)
CoordInputDependencyaddInputInstanceList in interface CoordInputDependencyinputEventName - the input event nameinputInstanceList - the input instance listpublic String getMissingDependencies()
CoordInputDependencygetMissingDependencies in interface CoordInputDependencypublic boolean isDependencyMet()
CoordInputDependencyisDependencyMet in interface CoordInputDependencypublic boolean isUnResolvedDependencyMet()
CoordInputDependencyisUnResolvedDependencyMet in interface CoordInputDependencypublic void setDependencyMet(boolean isDependencyMeet)
CoordInputDependencysetDependencyMet in interface CoordInputDependencyisDependencyMeet - the new dependency metpublic String serialize() throws IOException
CoordInputDependencyserialize in interface CoordInputDependencyIOException - Signals that an I/O exception has occurred.public List<String> getMissingDependenciesAsList()
CoordInputDependencygetMissingDependenciesAsList in interface CoordInputDependencypublic List<String> getAvailableDependenciesAsList()
CoordInputDependencygetAvailableDependenciesAsList in interface CoordInputDependencypublic void setMissingDependencies(String missingDependencies)
CoordInputDependencysetMissingDependencies in interface CoordInputDependencymissingDependencies - the new missing dependenciespublic void appendToDependencies(List<CoordInputInstance> inputInstanceList)
public void addUnResolvedList(String name, String unresolvedDependencies)
CoordInputDependencyaddUnResolvedList in interface CoordInputDependencyname - the nameunresolvedDependencies - the tmp unresolvedpublic List<String> getAvailableDependencies(String dataSet)
CoordInputDependencygetAvailableDependencies in interface CoordInputDependencydataSet - the data setpublic void addToAvailableDependencies(Collection<String> availableList)
CoordInputDependencyaddToAvailableDependencies in interface CoordInputDependencyavailableList - the avail dep listpublic boolean checkPullMissingDependencies(CoordinatorActionBean coordAction, StringBuilder existList, StringBuilder nonExistList) throws IOException, org.jdom.JDOMException
CoordInputDependencycheckPullMissingDependencies in interface CoordInputDependencycoordAction - the coord actionexistList - the exist listnonExistList - the non exist listIOException - Signals that an I/O exception has occurred.org.jdom.JDOMException - the JDOM exceptionpublic ActionDependency checkPushMissingDependencies(CoordinatorActionBean coordAction, boolean registerForNotification) throws CommandException, IOException
CoordInputDependencycheckPushMissingDependencies in interface CoordInputDependencycoordAction - the coord actionregisterForNotification - the register for notificationCommandException - the command exceptionIOException - Signals that an I/O exception has occurred.public boolean pathExists(CoordinatorActionBean coordAction, String sPath, org.apache.hadoop.conf.Configuration actionConf, String user) throws IOException
IOExceptionpublic boolean isChangeInDependency(StringBuilder nonExistList, String missingDependencies, StringBuilder nonResolvedList, boolean status)
CoordInputDependencyisChangeInDependency in interface CoordInputDependencynonExistList - the non exist listmissingDependencies - the missing dependenciesnonResolvedList - the non resolved liststatus - the statuspublic boolean checkUnresolved(CoordinatorActionBean coordAction, org.jdom.Element eAction) throws Exception
CoordInputDependencycheckUnresolved in interface CoordInputDependencycoordAction - the coord actionException - the exceptionCopyright © 2018 Apache Software Foundation. All rights reserved.