我有sparkscala应用程序。我正在尝试使用它内部的Futures来并行化几个独立的操作集。我在期货中调用它们,它们返回给我未来类型的DataFrame,我如何在最后合并它们,并在任何未来类型无法计算的情况下抛出错误。下面是我的代码。当我尝试在onComplete块中应用数据帧的联合时,它显示以下错误
value union is not a member of scala.concurrent.Future[(scala.co
我们如何在一个数据帧中的多个列上进行透视。例如,这里提到的例子,https://spark.apache.org/docs/latest/sql-ref-syntax-qry-select-pivot.html SELECT * FROM person我们不能在Sparkscala的pivot方法中传递多个参数,因为它只需要一个列名作为参数。我们如何对数据帧
num-master 1-num-工2-主机器类型n1-工-工-机器类型n1-标准-1-元数据spark-packages=graphframes:graphframes:0.2.0-spark2.1-找到图形框架#图形框架;0.2.0-火花2.0-s_2.11在火花包中
成功的graphframes#graphframes;0.2.0-spark2.0-s_2.11!graphframes#graphframes;0.2.0-spark2.0-s_2.11 from spark