Package 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	Description
ClosureCleaner()

Method Summary

Modifier and Type	Method	Description
static void	clean(Object closure, boolean checkSerializable, boolean cleanTransitively)	Clean the given closure in place.
static org.slf4j.Logger	org$apache$spark$internal$Logging$$log_()
static void	org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)

Methods inherited from class java.lang.Object

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

Constructor Details

ClosureCleaner

public ClosureCleaner()

Method Details

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

org$apache$spark$internal$Logging$$log_

public static org.slf4j.Logger org$apache$spark$internal$Logging$$log_()

org$apache$spark$internal$Logging$$log__$eq

public static void org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)