手动指定选择项

你也可以通过额外的选择项来传递数据源,手动指定数据源。数据源通过他们全限定修饰符名称(例如,org.apache.spark.sql.parquet),但对于内置的数据源,你也可以使用简短的名字(json,parquet,jdbc)。任何类型的DataFrames能够使用这种语法转换成其也类型。

val df = sqlContext.read.format("json").load("examples/src/main/resources/people.json")
df.select("name", "age").write.format("parquet").save("namesAndAges.parquet")

results matching ""

    No results matching ""