spark-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Michal Šenkýř <mike.sen...@gmail.com>
Subject Re: how to dynamic partition dataframe
Date Thu, 19 Jan 2017 11:55:05 GMT
Hi,

You can pass Seqs as varargs in Scala using this syntax:

df.partitionBy(seq: _*)

Michal


On 18.1.2017 03:23, lk_spark wrote:
> hi,all:
>     I want partition data by reading a config file who tells me how to 
> partition current input data.
>     DataFrameWriter have a method named with : partitionBy(colNames: 
> String*): DataFrameWriter[T]
>     why I can't pass parameter format with Seq[String] or Array[String]?
> 2017-01-18
> ------------------------------------------------------------------------
> lk_spark


Mime
View raw message