org.apache.spark.util

Class ClosureCleaner

Object

org.apache.spark.util.ClosureCleaner

public class ClosureCleaner
extends Object

A cleaner that renders closures serializable if they can be done so safely.

Constructor Summary

Constructors

Constructor and Description
ClosureCleaner()

Method Summary

Modifier and Type	Method and Description
static void	clean(Object closure, boolean checkSerializable, boolean cleanTransitively) Clean the given closure in place.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClosureCleaner

public ClosureCleaner()

Method Detail

clean

public static void clean(Object closure,
                         boolean checkSerializable,
                         boolean cleanTransitively)

Clean the given closure in place.

More specifically, this renders the given closure serializable as long as it does not explicitly reference unserializable objects.

Parameters:

closure - the closure to clean

checkSerializable - whether to verify that the closure is serializable after cleaning

cleanTransitively - whether to clean enclosing closures transitively