Package org.apache.sysds.hops.rewrite
Class RewriteInjectSparkPReadCheckpointing
- java.lang.Object
- 
- org.apache.sysds.hops.rewrite.HopRewriteRule
- 
- org.apache.sysds.hops.rewrite.RewriteInjectSparkPReadCheckpointing
 
 
- 
 public class RewriteInjectSparkPReadCheckpointing extends HopRewriteRule Rule: BlockSizeAndReblock. For all statement blocks, determine "optimal" block size, and place reblock Hops. For now, we just use BlockSize 1K x 1K and do reblock after Persistent Reads and before Persistent Writes.
- 
- 
Constructor SummaryConstructors Constructor Description RewriteInjectSparkPReadCheckpointing()
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description HoprewriteHopDAG(Hop root, ProgramRewriteStatus state)Handle a predicate hop DAG with exactly one root.ArrayList<Hop>rewriteHopDAGs(ArrayList<Hop> roots, ProgramRewriteStatus state)Handle a generic (last-level) hop DAG with multiple roots.
 
- 
- 
- 
Method Detail- 
rewriteHopDAGspublic ArrayList<Hop> rewriteHopDAGs(ArrayList<Hop> roots, ProgramRewriteStatus state) Description copied from class:HopRewriteRuleHandle a generic (last-level) hop DAG with multiple roots.- Specified by:
- rewriteHopDAGsin class- HopRewriteRule
- Parameters:
- roots- high-level operator roots
- state- program rewrite status
- Returns:
- list of high-level operators
 
 - 
rewriteHopDAGpublic Hop rewriteHopDAG(Hop root, ProgramRewriteStatus state) Description copied from class:HopRewriteRuleHandle a predicate hop DAG with exactly one root.- Specified by:
- rewriteHopDAGin class- HopRewriteRule
- Parameters:
- root- high-level operator root
- state- program rewrite status
- Returns:
- high-level operator
 
 
- 
 
-