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 |
getFirstMissingDependency()
Gets the first missing dependency.
|
String |
getMissingDependencies()
Gets the missing dependencies.
|
Map<String,ActionDependency> |
getMissingDependencies(CoordinatorActionBean coordAction)
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)
CoordInputDependency
addInputInstanceList
in interface CoordInputDependency
inputEventName
- the input event nameinputInstanceList
- the input instance listpublic String getMissingDependencies()
CoordInputDependency
getMissingDependencies
in interface CoordInputDependency
public boolean isDependencyMet()
CoordInputDependency
isDependencyMet
in interface CoordInputDependency
public boolean isUnResolvedDependencyMet()
CoordInputDependency
isUnResolvedDependencyMet
in interface CoordInputDependency
public void setDependencyMet(boolean isDependencyMeet)
CoordInputDependency
setDependencyMet
in interface CoordInputDependency
isDependencyMeet
- the new dependency metpublic String serialize() throws IOException
CoordInputDependency
serialize
in interface CoordInputDependency
IOException
- Signals that an I/O exception has occurred.public List<String> getMissingDependenciesAsList()
CoordInputDependency
getMissingDependenciesAsList
in interface CoordInputDependency
public List<String> getAvailableDependenciesAsList()
CoordInputDependency
getAvailableDependenciesAsList
in interface CoordInputDependency
public void setMissingDependencies(String missingDependencies)
CoordInputDependency
setMissingDependencies
in interface CoordInputDependency
missingDependencies
- the new missing dependenciespublic void appendToDependencies(List<CoordInputInstance> inputInstanceList)
public void addUnResolvedList(String name, String unresolvedDependencies)
CoordInputDependency
addUnResolvedList
in interface CoordInputDependency
name
- the nameunresolvedDependencies
- the tmp unresolvedpublic List<String> getAvailableDependencies(String dataSet)
CoordInputDependency
getAvailableDependencies
in interface CoordInputDependency
dataSet
- the data setpublic void addToAvailableDependencies(Collection<String> availableList)
CoordInputDependency
addToAvailableDependencies
in interface CoordInputDependency
availableList
- the avail dep listpublic boolean checkPullMissingDependencies(CoordinatorActionBean coordAction, StringBuilder existList, StringBuilder nonExistList) throws IOException, org.jdom.JDOMException
CoordInputDependency
checkPullMissingDependencies
in interface CoordInputDependency
coordAction
- 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
CoordInputDependency
checkPushMissingDependencies
in interface CoordInputDependency
coordAction
- 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
IOException
public boolean isChangeInDependency(StringBuilder nonExistList, String missingDependencies, StringBuilder nonResolvedList, boolean status)
CoordInputDependency
isChangeInDependency
in interface CoordInputDependency
nonExistList
- the non exist listmissingDependencies
- the missing dependenciesnonResolvedList
- the non resolved liststatus
- the statuspublic boolean checkUnresolved(CoordinatorActionBean coordAction, org.jdom.Element eAction) throws Exception
CoordInputDependency
checkUnresolved
in interface CoordInputDependency
coordAction
- the coord actioneAction
- the element for the actionException
- the exceptionpublic Map<String,ActionDependency> getMissingDependencies(CoordinatorActionBean coordAction) throws CommandException, IOException, org.jdom.JDOMException
CoordInputDependency
getMissingDependencies
in interface CoordInputDependency
coordAction
- the coord actionCommandException
- the command exceptionIOException
- Signals that an I/O exception has occurred.org.jdom.JDOMException
- the JDOM exceptionpublic String getFirstMissingDependency()
CoordInputDependency
getFirstMissingDependency
in interface CoordInputDependency
Copyright © 2018 Apache Software Foundation. All rights reserved.