Class 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 Detail

      • RewriteInjectSparkPReadCheckpointing

        public RewriteInjectSparkPReadCheckpointing()