@@ -524,7 +524,7 @@ class Dataset[T] private[sql](
524524 */
525525 @ Experimental
526526 @ InterfaceStability .Evolving
527- def checkpoint (): Dataset [T ] = _checkpoint (eager = true )
527+ def checkpoint (): Dataset [T ] = checkpoint (eager = true , local = false )
528528
529529 /**
530530 * Returns a checkpointed version of this Dataset. Checkpointing can be used to truncate the
@@ -537,7 +537,7 @@ class Dataset[T] private[sql](
537537 */
538538 @ Experimental
539539 @ InterfaceStability .Evolving
540- def checkpoint (eager : Boolean ): Dataset [T ] = _checkpoint (eager = eager)
540+ def checkpoint (eager : Boolean ): Dataset [T ] = checkpoint (eager = eager, local = false )
541541
542542 /**
543543 * Eagerly locally checkpoints a Dataset and return the new Dataset. Checkpointing can be
@@ -550,7 +550,7 @@ class Dataset[T] private[sql](
550550 */
551551 @ Experimental
552552 @ InterfaceStability .Evolving
553- def localCheckpoint (): Dataset [T ] = _checkpoint (eager = true , local = true )
553+ def localCheckpoint (): Dataset [T ] = checkpoint (eager = true , local = true )
554554
555555 /**
556556 * Locally checkpoints a Dataset and return the new Dataset. Checkpointing can be used to truncate
@@ -563,7 +563,7 @@ class Dataset[T] private[sql](
563563 */
564564 @ Experimental
565565 @ InterfaceStability .Evolving
566- def localCheckpoint (eager : Boolean ): Dataset [T ] = _checkpoint (eager = eager, local = true )
566+ def localCheckpoint (eager : Boolean ): Dataset [T ] = checkpoint (eager = eager, local = true )
567567
568568 /**
569569 * Returns a checkpointed version of this Dataset. Checkpointing can be used to truncate the
@@ -579,7 +579,7 @@ class Dataset[T] private[sql](
579579 */
580580 @ Experimental
581581 @ InterfaceStability .Evolving
582- private [sql] def _checkpoint (eager : Boolean , local : Boolean = false ): Dataset [T ] = {
582+ private [sql] def checkpoint (eager : Boolean , local : Boolean ): Dataset [T ] = {
583583 val internalRdd = queryExecution.toRdd.map(_.copy())
584584 if (local) {
585585 internalRdd.localCheckpoint()
0 commit comments