public class DefaultSource extends Object implements RelationProvider
CREATE TEMPORARY TABLE ... USING org.apache.spark.sql.parquet
. Currently the only option
required is path
, which should be the location of a collection of, optionally partitioned,
parquet files.Constructor and Description |
---|
DefaultSource() |
Modifier and Type | Method and Description |
---|---|
BaseRelation |
createRelation(SQLContext sqlContext,
scala.collection.immutable.Map<String,String> parameters)
Returns a new base relation with the given parameters.
|
public BaseRelation createRelation(SQLContext sqlContext, scala.collection.immutable.Map<String,String> parameters)
createRelation
in interface RelationProvider