Class RDDObject
- java.lang.Object
- 
- org.apache.sysds.runtime.instructions.spark.data.LineageObject
- 
- org.apache.sysds.runtime.instructions.spark.data.RDDObject
 
 
- 
 public class RDDObject extends LineageObject 
- 
- 
Constructor SummaryConstructors Constructor Description RDDObject(org.apache.spark.api.java.JavaPairRDD<?,?> rddvar)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanallowsShortCircuitCollect()booleanallowsShortCircuitRead()Indicates if rdd is an hdfs file or a checkpoint over an hdfs file; in both cases, we can directly read the file instead of collecting the given rdd.StringgetHDFSFilename()org.apache.spark.api.java.JavaPairRDD<?,?>getRDD()booleanisCheckpointRDD()booleanisHDFSFile()booleanisParallelizedRDD()booleanisPending()booleanrHasCheckpointRDDChilds()voidsetCheckpointRDD(boolean flag)voidsetHDFSFile(boolean flag)voidsetHDFSFilename(String fname)voidsetParallelizedRDD(boolean flag)voidsetPending(boolean flag)- 
Methods inherited from class org.apache.sysds.runtime.instructions.spark.data.LineageObjectaddLineageChild, decrementNumReferences, getLineageChilds, getNumReferences, hasBackReference, incrementNumReferences, setBackReference
 
- 
 
- 
- 
- 
Method Detail- 
getRDDpublic org.apache.spark.api.java.JavaPairRDD<?,?> getRDD() 
 - 
setCheckpointRDDpublic void setCheckpointRDD(boolean flag) 
 - 
isCheckpointRDDpublic boolean isCheckpointRDD() 
 - 
setHDFSFilepublic void setHDFSFile(boolean flag) 
 - 
setHDFSFilenamepublic void setHDFSFilename(String fname) 
 - 
isHDFSFilepublic boolean isHDFSFile() 
 - 
getHDFSFilenamepublic String getHDFSFilename() 
 - 
setParallelizedRDDpublic void setParallelizedRDD(boolean flag) 
 - 
isParallelizedRDDpublic boolean isParallelizedRDD() 
 - 
setPendingpublic void setPending(boolean flag) 
 - 
isPendingpublic boolean isPending() 
 - 
allowsShortCircuitReadpublic boolean allowsShortCircuitRead() Indicates if rdd is an hdfs file or a checkpoint over an hdfs file; in both cases, we can directly read the file instead of collecting the given rdd.- Returns:
- true if rdd is an hdfs file or a checkpoint over an hdfs file
 
 - 
allowsShortCircuitCollectpublic boolean allowsShortCircuitCollect() 
 - 
rHasCheckpointRDDChildspublic boolean rHasCheckpointRDDChilds() 
 
- 
 
-