public class CoordPullInputDependency extends AbstractCoordInputDependency
availableDependenciesSet, dependencyMap, isDependencyMet, missingDependenciesSet
INTERNAL_VERSION_ID
Constructor and Description |
---|
CoordPullInputDependency() |
Modifier and Type | Method and Description |
---|---|
void |
addResolvedList(String dataSet,
String list) |
void |
addUnResolvedList(String dataSet,
String dependency)
Adds the un resolved list.
|
protected void |
generateDependencies() |
List<String> |
getAvailableDependencies(String dataSet)
Gets the available dependencies.
|
String |
getMissingDependencies()
Gets the missing dependencies.
|
CoordUnResolvedInputDependency |
getUnResolvedDependency(String dataSet) |
String |
getUnresolvedMissingDependencies() |
boolean |
isDataSetResolved(String dataSet) |
boolean |
isDependencyMet()
Checks if dependencies are meet.
|
boolean |
isResolvedDependencyMeet() |
boolean |
isUnResolvedDependencyMet()
Checks if is unresolved dependencies met.
|
void |
readFields(DataInput in) |
void |
setMissingDependencies(String join)
Sets the missing dependencies.
|
void |
write(DataOutput out) |
addInputInstanceList, addToAvailableDependencies, addToAvailableDependencies, addToAvailableDependencies, addToMissingDependencies, checkPullMissingDependencies, checkPushMissingDependencies, checkUnresolved, getAvailableDependenciesAsList, getDependencyMap, getListAsString, getMissingDependencies, getMissingDependenciesAsList, isChangeInDependency, removeFromMissingDependencies, serialize, setDependencyMap, setDependencyMet
public CoordPullInputDependency()
public void addResolvedList(String dataSet, String list)
public CoordUnResolvedInputDependency getUnResolvedDependency(String dataSet)
public boolean isUnResolvedDependencyMet()
CoordInputDependency
isUnResolvedDependencyMet
in interface CoordInputDependency
isUnResolvedDependencyMet
in class AbstractCoordInputDependency
public void addUnResolvedList(String dataSet, String dependency)
CoordInputDependency
dataSet
- the namedependency
- the tmp unresolvedpublic String getMissingDependencies()
CoordInputDependency
getMissingDependencies
in interface CoordInputDependency
getMissingDependencies
in class AbstractCoordInputDependency
public String getUnresolvedMissingDependencies()
protected void generateDependencies()
generateDependencies
in class AbstractCoordInputDependency
public boolean isDependencyMet()
CoordInputDependency
isDependencyMet
in interface CoordInputDependency
isDependencyMet
in class AbstractCoordInputDependency
public boolean isResolvedDependencyMeet()
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
write
in class AbstractCoordInputDependency
IOException
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
readFields
in class AbstractCoordInputDependency
IOException
public void setMissingDependencies(String join)
CoordInputDependency
join
- the new missing dependenciespublic List<String> getAvailableDependencies(String dataSet)
CoordInputDependency
getAvailableDependencies
in interface CoordInputDependency
getAvailableDependencies
in class AbstractCoordInputDependency
dataSet
- the data setpublic boolean isDataSetResolved(String dataSet)
isDataSetResolved
in class AbstractCoordInputDependency
Copyright © 2016 Apache Software Foundation. All rights reserved.