Java中的"Lambdifying"scala函数

ovn*_*nia 1 java lambda scala traits apache-spark

使用Java和Apache Spark(已经在Scala中重写),面对旧的API方法(org.apache.spark.rdd.JdbcRDD构造函数),它有AbstractFunction1作为它的参数:

abstract class AbstractFunction1[@scala.specialized -T1, @scala.specialized +R]() extends scala.AnyRef with scala.Function1[T1, R] {}
Run Code Online (Sandbox Code Playgroud)

因为AbstractFunction1是一个抽象类,我不能使用Java8 lambdas,所以我决定包装scala.Function1 trait是相同的java.util.functions.Function但不是实现andThencompose方法.结果,我创建了thes接口:

import scala.Function1;

@FunctionalInterface
public interface Funct<T, R> extends Function1<T, R>, Serializable {

    @Override
    default <A> Function1<A, R> compose(Function1<A, T> before) {
        return null;
    }

    @Override
    default <A> Function1<T, A> andThen(Function1<R, A> g) {
        return null;
    }
}
Run Code Online (Sandbox Code Playgroud)

IDE对此接口没有任何问题,但在编译时,get:

[ERROR] Funct is not a functional interface
[ERROR] multiple non-overriding abstract methods found in interface Funct
Run Code Online (Sandbox Code Playgroud)

是否可以包装Scala的特性,我可以使用lambdas方法:

void doMagic(scala.Function1<T,V> arg)
Run Code Online (Sandbox Code Playgroud)

Rüd*_*ehn 7

那么你想要一个scala函数特征的功能接口版本,这样你就可以用java8 lambda语法调用它们吗?你不必自己做.看看https://github.com/scala/scala-java8-compat.它不如直接使用java8 lambda语法那么好,因为你仍然需要这样做

import static scala.compat.java8.JFunction.*;
doMagic(func(x => ...));
Run Code Online (Sandbox Code Playgroud)

代替

doMagic(x => ...);
Run Code Online (Sandbox Code Playgroud)

但在Scala 2.12中,一个重要的主题是Java8兼容性.scala FunctionX类本身将作为SAM接口重做,因此当scala 2.12出现时,您将能够执行后者.至少那是我上次检查时的计划.

  • 说得通.也许你可以看一下scala-java8-compat的来源,看看他们是怎么做到的? (2认同)