org.apache.oozie.coord.input.dependency

Class CoordOldInputDependency

java.lang.Object

org.apache.oozie.coord.input.dependency.CoordOldInputDependency

All Implemented Interfaces:

CoordInputDependency

public class CoordOldInputDependency
extends Object
implements CoordInputDependency

Old approach where dependencies are stored as String.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	missingDependencies

Fields inherited from interface org.apache.oozie.coord.input.dependency.CoordInputDependency

INTERNAL_VERSION_ID

Constructor Summary

Constructors

Constructor and Description
CoordOldInputDependency()
CoordOldInputDependency(String missingDependencies)

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

missingDependencies

protected transient String missingDependencies

Constructor Detail

CoordOldInputDependency

public CoordOldInputDependency(String missingDependencies)

CoordOldInputDependency

public CoordOldInputDependency()

Method Detail

addInputInstanceList

public void addInputInstanceList(String inputEventName,
                                 List<CoordInputInstance> inputInstanceList)

Description copied from interface: CoordInputDependency

Adds the input instance list.

Specified by:

addInputInstanceList in interface CoordInputDependency

Parameters:

inputEventName - the input event name

inputInstanceList - the input instance list

getMissingDependencies

public String getMissingDependencies()

Description copied from interface: CoordInputDependency

Gets the missing dependencies.

Specified by:

getMissingDependencies in interface CoordInputDependency

Returns:

the missing dependencies

isDependencyMet

public boolean isDependencyMet()

Description copied from interface: CoordInputDependency

Checks if dependencies are meet.

Specified by:

isDependencyMet in interface CoordInputDependency

Returns:

true, if dependencies are meet

isUnResolvedDependencyMet

public boolean isUnResolvedDependencyMet()

Description copied from interface: CoordInputDependency

Checks if is unresolved dependencies met.

Specified by:

isUnResolvedDependencyMet in interface CoordInputDependency

Returns:

true, if unresolved dependencies are met

setDependencyMet

public void setDependencyMet(boolean isDependencyMeet)

Description copied from interface: CoordInputDependency

Sets the dependency meet.

Specified by:

setDependencyMet in interface CoordInputDependency

Parameters:

isDependencyMeet - the new dependency met

serialize

public String serialize()
                 throws IOException

Description copied from interface: CoordInputDependency

Serialize.

Specified by:

serialize in interface CoordInputDependency

Returns:

the string

Throws:

IOException - Signals that an I/O exception has occurred.

getMissingDependenciesAsList

public List<String> getMissingDependenciesAsList()

Description copied from interface: CoordInputDependency

Gets the missing dependencies as list.

Specified by:

getMissingDependenciesAsList in interface CoordInputDependency

Returns:

the missing dependencies as list

getAvailableDependenciesAsList

public List<String> getAvailableDependenciesAsList()

Description copied from interface: CoordInputDependency

Gets the available dependencies as list.

Specified by:

getAvailableDependenciesAsList in interface CoordInputDependency

Returns:

the available dependencies as list

setMissingDependencies

public void setMissingDependencies(String missingDependencies)

Description copied from interface: CoordInputDependency

Sets the missing dependencies.

Specified by:

setMissingDependencies in interface CoordInputDependency

Parameters:

missingDependencies - the new missing dependencies

appendToDependencies

public void appendToDependencies(List<CoordInputInstance> inputInstanceList)

addUnResolvedList

public void addUnResolvedList(String name,
                              String unresolvedDependencies)

Description copied from interface: CoordInputDependency

Adds the un resolved list.

Specified by:

addUnResolvedList in interface CoordInputDependency

Parameters:

name - the name

unresolvedDependencies - the tmp unresolved

getAvailableDependencies

public List<String> getAvailableDependencies(String dataSet)

Description copied from interface: CoordInputDependency

Gets the available dependencies.

Specified by:

getAvailableDependencies in interface CoordInputDependency

Parameters:

dataSet - the data set

Returns:

the available dependencies

addToAvailableDependencies

public void addToAvailableDependencies(Collection<String> availableList)

Description copied from interface: CoordInputDependency

Adds the to available dependencies.

Specified by:

addToAvailableDependencies in interface CoordInputDependency

Parameters:

availableList - the avail dep list

checkPullMissingDependencies

public boolean checkPullMissingDependencies(CoordinatorActionBean coordAction,
                                            StringBuilder existList,
                                            StringBuilder nonExistList)
                                     throws IOException,
                                            org.jdom.JDOMException

Description copied from interface: CoordInputDependency

Check pull missing dependencies.

Specified by:

checkPullMissingDependencies in interface CoordInputDependency

Parameters:

coordAction - the coord action

existList - the exist list

nonExistList - the non exist list

Returns:

true, if successful

Throws:

IOException - Signals that an I/O exception has occurred.

org.jdom.JDOMException - the JDOM exception

checkPushMissingDependencies

public ActionDependency checkPushMissingDependencies(CoordinatorActionBean coordAction,
                                                     boolean registerForNotification)
                                              throws CommandException,
                                                     IOException

Description copied from interface: CoordInputDependency

Check push missing dependencies.

Specified by:

checkPushMissingDependencies in interface CoordInputDependency

Parameters:

coordAction - the coord action

registerForNotification - the register for notification

Returns:

the action dependency

Throws:

CommandException - the command exception

IOException - Signals that an I/O exception has occurred.

pathExists

public boolean pathExists(CoordinatorActionBean coordAction,
                          String sPath,
                          org.apache.hadoop.conf.Configuration actionConf,
                          String user)
                   throws IOException

Throws:

IOException

isChangeInDependency

public boolean isChangeInDependency(StringBuilder nonExistList,
                                    String missingDependencies,
                                    StringBuilder nonResolvedList,
                                    boolean status)

Description copied from interface: CoordInputDependency

Checks if is change in dependency.

Specified by:

isChangeInDependency in interface CoordInputDependency

Parameters:

nonExistList - the non exist list

missingDependencies - the missing dependencies

nonResolvedList - the non resolved list

status - the status

Returns:

true, if is change in dependency

checkUnresolved

public boolean checkUnresolved(CoordinatorActionBean coordAction,
                               org.jdom.Element eAction)
                        throws Exception

Description copied from interface: CoordInputDependency

Check unresolved.

Specified by:

checkUnresolved in interface CoordInputDependency

Parameters:

coordAction - the coord action

eAction - the element for the action

Returns:

true, if successful

Throws:

Exception - the exception

getMissingDependencies

public Map<String,ActionDependency> getMissingDependencies(CoordinatorActionBean coordAction)
                                                    throws CommandException,
                                                           IOException,
                                                           org.jdom.JDOMException

Description copied from interface: CoordInputDependency

Gets the missing dependencies.

Specified by:

getMissingDependencies in interface CoordInputDependency

Parameters:

coordAction - the coord action

Returns:

the missing dependencies

Throws:

CommandException - the command exception

IOException - Signals that an I/O exception has occurred.

org.jdom.JDOMException - the JDOM exception

getFirstMissingDependency

public String getFirstMissingDependency()

Description copied from interface: CoordInputDependency

Gets the first missing dependency.

Specified by:

getFirstMissingDependency in interface CoordInputDependency

Returns:

the first missing dependency