有时你可能需要对DataFrame执行多项变换

scache.sql函数._grache.sql.dataFrame测试Df=1至10df

应用这些变换时,最后可能使用像这个式的意大利面条码

scala def inc(i: int) =i+1valtm0=func0

文章描述多项简化链式变换法

数据Frame变换API系统

从Spark功能编程风格中受益,您可以利用DataFrame变换API,例如

scala val Res=testDf. transform(func0+3)

函数.链API系统

更深入地讲,你可以利用Scala函数库链式变换方式,例如

scalaval链化函数

隐式类

另一种选择是定义Scala隐式类中允许删除DataFrame变换API:

scala隐式 My transforms(df:DataFrame){defffunc0/

并直接调用函数

scala valRes=TestDf.func0(inc,1).func1(2).func2(3)