org.apache.spark.util

Class IndylambdaScalaClosures

Object

org.apache.spark.util.IndylambdaScalaClosures

public class IndylambdaScalaClosures
extends Object

Constructor Summary

Constructors

Constructor and Description
IndylambdaScalaClosures()

Method Summary

Modifier and Type	Method and Description
static void	findAccessedFields(java.lang.invoke.SerializedLambda lambdaProxy, ClassLoader lambdaClassLoader, scala.collection.mutable.Map<Class<?>,scala.collection.mutable.Set<String>> accessedFields, boolean findTransitively) Scans an indylambda Scala closure, along with its lexically nested closures, and populate the accessed fields info on which fields on the outer object are accessed.
static scala.Option<java.lang.invoke.SerializedLambda>	getSerializationProxy(Object maybeClosure) Check if the given reference is a indylambda style Scala closure.
static java.lang.invoke.SerializedLambda	inspect(Object closure)
static boolean	isIndylambdaScalaClosure(java.lang.invoke.SerializedLambda lambdaProxy)
static boolean	isInnerClassCtorCapturingOuter(int op, String owner, String name, String desc, String callerInternalName) Check if the callee of a call site is a inner class constructor.
static boolean	isLambdaBodyCapturingOuter(org.apache.xbean.asm7.Handle handle, String ownerInternalName) Check if the handle represents a target method that is: - a STATIC method that implements a Scala lambda body in the indylambda style - captures the enclosing this, i.e.
static boolean	isLambdaMetafactory(org.apache.xbean.asm7.Handle bsmHandle) Check if the handle represents the LambdaMetafactory that indylambda Scala closures use for creating the lambda class and getting a closure instance.
static String	LambdaMetafactoryClassName()
static String	LambdaMetafactoryMethodDesc()
static String	LambdaMetafactoryMethodName()
static void	org$apache$spark$internal$Logging$$log__$eq(org.slf4j.Logger x$1)
static org.slf4j.Logger	org$apache$spark$internal$Logging$$log_()

Methods inherited from class Object

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

Constructor Detail

IndylambdaScalaClosures

public IndylambdaScalaClosures()

Method Detail

LambdaMetafactoryClassName

public static String LambdaMetafactoryClassName()

LambdaMetafactoryMethodName

public static String LambdaMetafactoryMethodName()

LambdaMetafactoryMethodDesc

public static String LambdaMetafactoryMethodDesc()

getSerializationProxy

public static scala.Option<java.lang.invoke.SerializedLambda> getSerializationProxy(Object maybeClosure)

Check if the given reference is a indylambda style Scala closure. If so (e.g. for Scala 2.12+ closures), return a non-empty serialization proxy (SerializedLambda) of the closure; otherwise (e.g. for Scala 2.11 closures) return None.

Parameters:

maybeClosure - the closure to check.

Returns:

(undocumented)

isIndylambdaScalaClosure

public static boolean isIndylambdaScalaClosure(java.lang.invoke.SerializedLambda lambdaProxy)

inspect

public static java.lang.invoke.SerializedLambda inspect(Object closure)

isLambdaMetafactory

public static boolean isLambdaMetafactory(org.apache.xbean.asm7.Handle bsmHandle)

Check if the handle represents the LambdaMetafactory that indylambda Scala closures use for creating the lambda class and getting a closure instance.

Parameters:

bsmHandle - (undocumented)

Returns:

(undocumented)

isLambdaBodyCapturingOuter

public static boolean isLambdaBodyCapturingOuter(org.apache.xbean.asm7.Handle handle,
                                                 String ownerInternalName)

Check if the handle represents a target method that is: - a STATIC method that implements a Scala lambda body in the indylambda style - captures the enclosing this, i.e. the first argument is a reference to the same type as the owning class. Returns true if both criteria above are met.

Parameters:

handle - (undocumented)

ownerInternalName - (undocumented)

Returns:

(undocumented)

isInnerClassCtorCapturingOuter

public static boolean isInnerClassCtorCapturingOuter(int op,
                                                     String owner,
                                                     String name,
                                                     String desc,
                                                     String callerInternalName)

Check if the callee of a call site is a inner class constructor. - A constructor has to be invoked via INVOKESPECIAL - A constructor's internal name is "<init>" and the return type is "V" (void) - An inner class' first argument in the signature has to be a reference to the enclosing "this", aka $outer in Scala.

Parameters:

op - (undocumented)

owner - (undocumented)

name - (undocumented)

desc - (undocumented)

callerInternalName - (undocumented)

Returns:

(undocumented)

findAccessedFields

public static void findAccessedFields(java.lang.invoke.SerializedLambda lambdaProxy,
                                      ClassLoader lambdaClassLoader,
                                      scala.collection.mutable.Map<Class<?>,scala.collection.mutable.Set<String>> accessedFields,
                                      boolean findTransitively)

Scans an indylambda Scala closure, along with its lexically nested closures, and populate the accessed fields info on which fields on the outer object are accessed.

This is equivalent to getInnerClosureClasses() + InnerClosureFinder + FieldAccessFinder fused into one for processing indylambda closures. The traversal order along the call graph is the same for all three combined, so they can be fused together easily while maintaining the same ordering as the existing implementation.

Precondition: this function expects the accessedFields to be populated with all known outer classes and their super classes to be in the map as keys, e.g. initializing via ClosureCleaner.initAccessedFields.

Parameters:

lambdaProxy - (undocumented)

lambdaClassLoader - (undocumented)

accessedFields - (undocumented)

findTransitively - (undocumented)

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)