org.apache.spark.sql.parquet

Class DefaultSource

Object

org.apache.spark.sql.parquet.DefaultSource

All Implemented Interfaces:

RelationProvider

public class DefaultSource
extends Object
implements RelationProvider

Allows creation of parquet based tables using the syntax 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 Summary

Constructors

Constructor and Description
DefaultSource()

Method Summary

Methods

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.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultSource

public DefaultSource()

Method Detail

createRelation

public BaseRelation createRelation(SQLContext sqlContext,
                          scala.collection.immutable.Map<String,String> parameters)

Returns a new base relation with the given parameters.

Specified by:

createRelation in interface RelationProvider