org.apache.oozie.coord.input.dependency

Class AbstractCoordInputDependency

java.lang.Object

org.apache.oozie.coord.input.dependency.AbstractCoordInputDependency

All Implemented Interfaces:

org.apache.hadoop.io.Writable, CoordInputDependency

Direct Known Subclasses:

CoordPullInputDependency, CoordPushInputDependency

public abstract class AbstractCoordInputDependency
extends Object
implements org.apache.hadoop.io.Writable, CoordInputDependency

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,List<String>>	availableDependenciesSet
protected Map<String,List<CoordInputInstance>>	dependencyMap
protected boolean	isDependencyMet
protected Map<String,List<String>>	missingDependenciesSet

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

INTERNAL_VERSION_ID

Constructor Summary

Constructors

Constructor and Description
AbstractCoordInputDependency()
AbstractCoordInputDependency(Map<String,List<CoordInputInstance>> dependencyMap)

Method Summary

Methods

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	addToAvailableDependencies(String dataSet, CoordInputInstance coordInputInstance)
void	addToAvailableDependencies(String dataSet, String availableSet)
void	addToMissingDependencies(String dataSet, CoordInputInstance coordInputInstance)
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.
protected void	generateDependencies()
List<String>	getAvailableDependencies(String dataSet) Gets the available dependencies.
List<String>	getAvailableDependenciesAsList() Gets the available dependencies as list.
Map<String,List<CoordInputInstance>>	getDependencyMap()
String	getListAsString(List<String> dataSets)
String	getMissingDependencies() Gets the missing dependencies.
String	getMissingDependencies(String dataSet)
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	isDataSetResolved(String dataSet)
boolean	isDependencyMet() Checks if dependencies are meet.
boolean	isUnResolvedDependencyMet() Checks if is unresolved dependencies met.
void	readFields(DataInput in)
void	removeFromMissingDependencies(String dataSet, CoordInputInstance coordInputInstance)
String	serialize() Serialize.
void	setDependencyMap(Map<String,List<CoordInputInstance>> dependencyMap)
void	setDependencyMet(boolean isDependencyMeet) Sets the dependency meet.
void	write(DataOutput out)

Methods inherited from class java.lang.Object

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

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

addUnResolvedList, setMissingDependencies

Field Detail

isDependencyMet

protected boolean isDependencyMet

missingDependenciesSet

protected transient Map<String,List<String>> missingDependenciesSet

availableDependenciesSet

protected transient Map<String,List<String>> availableDependenciesSet

dependencyMap

protected Map<String,List<CoordInputInstance>> dependencyMap

Constructor Detail

AbstractCoordInputDependency

public AbstractCoordInputDependency()

AbstractCoordInputDependency

public AbstractCoordInputDependency(Map<String,List<CoordInputInstance>> dependencyMap)

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

getDependencyMap

public Map<String,List<CoordInputInstance>> getDependencyMap()

setDependencyMap

public void setDependencyMap(Map<String,List<CoordInputInstance>> dependencyMap)

addToAvailableDependencies

public void addToAvailableDependencies(String dataSet,
                              CoordInputInstance coordInputInstance)

removeFromMissingDependencies

public void removeFromMissingDependencies(String dataSet,
                                 CoordInputInstance coordInputInstance)

addToMissingDependencies

public void addToMissingDependencies(String dataSet,
                            CoordInputInstance coordInputInstance)

generateDependencies

protected void generateDependencies()

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

getMissingDependencies

public String getMissingDependencies(String dataSet)

addToAvailableDependencies

public void addToAvailableDependencies(String dataSet,
                              String availableSet)

getMissingDependencies

public String getMissingDependencies()

Description copied from interface: CoordInputDependency

Gets the missing dependencies.

Specified by:

getMissingDependencies in interface CoordInputDependency

Returns:

the missing dependencies

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

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.

getListAsString

public String getListAsString(List<String> dataSets)

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

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

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

checkPushMissingDependencies

public ActionDependency checkPushMissingDependencies(CoordinatorActionBean coordAction,
                                            boolean registerForNotification)
                                              throws CommandException,
                                                     IOException,
                                                     org.jdom.JDOMException

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.

org.jdom.JDOMException - the JDOM exception

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

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

Returns:

true, if successful

Throws:

Exception - the exception

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

isDataSetResolved

public boolean isDataSetResolved(String dataSet)