Scala 2.11类型不匹配报错：Scala函数无法适配java.util.function.Consumer

这个问题其实是Scala 2.11对Java 8函数式接口的自动适配限制导致的，我来给你拆解原因和修复方案：

问题根源 #

你写的(x: org.apache.pig.data.Tuple) => print(x)是Scala原生的Function1[Tuple, Unit]类型，而forEachRemaining方法要求的是Java 8的java.util.function.Consumer[_ >: Tuple]接口。在Scala 2.11中，编译器还不能自动把Scala的函数类型无缝转换成Java的函数式接口——这个特性是在Scala 2.12及以后版本才完善支持的，这就是为什么你的代码会被拒绝。

修复方案 #

有几种方式可以解决这个问题，你可以根据自己的场景选择：

1. 显式实现Java Consumer接口

最直接的方式就是手动创建Consumer的匿名实现类，绕过Scala函数的转换问题：

import java.util.function.Consumer

pigTest.getAlias("productData").forEachRemaining(new Consumer[org.apache.pig.data.Tuple] {
  override def accept(x: org.apache.pig.data.Tuple): Unit = {
    print(x)
  }
})

2. 定义隐式转换实现自动适配

如果你不想每次都写匿名类，可以定义一个全局的隐式转换方法，让Scala编译器自动把你的Scala函数转成Java Consumer：

import java.util.function.Consumer

// 定义隐式转换
implicit def scalaFuncToJavaConsumer[T](func: T => Unit): Consumer[T] = new Consumer[T] {
  override def accept(t: T): Unit = func(t)
}

// 现在你原来的代码就可以正常运行了
pigTest.getAlias("productData").forEachRemaining((x: org.apache.pig.data.Tuple) => print(x))

3. 升级到Scala 2.12+（推荐长期方案）

如果你的项目允许升级Scala版本，直接升到2.12或更高版本是最省心的。Scala 2.12开始完全兼容Java 8的函数式接口，你的原始代码不需要任何修改就能正常编译运行——编译器会自动帮你完成Scala函数到Java Consumer的转换。

内容的提问来源于stack exchange，提问作者Adair