DataStreamWriter.PartitionBy(String[]) Method

  • Reference

Definition

Namespace:
Microsoft.Spark.Sql.Streaming
Assembly:
Microsoft.Spark.dll
Package:
Microsoft.Spark v1.0.0

Partitions the output by the given columns on the file system. If specified, the output is laid out on the file system similar to Hive's partitioning scheme.

public Microsoft.Spark.Sql.Streaming.DataStreamWriter PartitionBy (params string[] colNames);
member this.PartitionBy : string[] -> Microsoft.Spark.Sql.Streaming.DataStreamWriter
Public Function PartitionBy (ParamArray colNames As String()) As DataStreamWriter

Parameters

colNames
String[]

Column names to partition by

Returns

DataStreamWriter

This DataStreamWriter object

Applies to