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 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)