org.apache.spark.sql.json

Class JSONRelation

Object

org.apache.spark.sql.sources.BaseRelation

org.apache.spark.sql.json.JSONRelation

All Implemented Interfaces:

java.io.Serializable, InsertableRelation, TableScan, scala.Equals, scala.Product

public class JSONRelation
extends BaseRelation
implements TableScan, InsertableRelation, scala.Product, scala.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JSONRelation(String path, double samplingRatio, scala.Option<org.apache.spark.sql.types.StructType> userSpecifiedSchema, SQLContext sqlContext)

Method Summary

Methods

Modifier and Type	Method and Description
RDD<org.apache.spark.sql.Row>	buildScan()
boolean	equals(Object other)
int	hashCode()
void	insert(DataFrame data, boolean overwrite)
String	path()
double	samplingRatio()
org.apache.spark.sql.types.StructType	schema()
SQLContext	sqlContext()
scala.Option<org.apache.spark.sql.types.StructType>	userSpecifiedSchema()

Methods inherited from class org.apache.spark.sql.sources.BaseRelation

sizeInBytes

Methods inherited from class Object

getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual

Constructor Detail

JSONRelation

public JSONRelation(String path,
            double samplingRatio,
            scala.Option<org.apache.spark.sql.types.StructType> userSpecifiedSchema,
            SQLContext sqlContext)

Method Detail

path

public String path()

samplingRatio

public double samplingRatio()

userSpecifiedSchema

public scala.Option<org.apache.spark.sql.types.StructType> userSpecifiedSchema()

sqlContext

public SQLContext sqlContext()

Specified by:

sqlContext in class BaseRelation

schema

public org.apache.spark.sql.types.StructType schema()

Specified by:

schema in class BaseRelation

buildScan

public RDD<org.apache.spark.sql.Row> buildScan()

Specified by:

buildScan in interface TableScan

insert

public void insert(DataFrame data,
          boolean overwrite)

Specified by:

insert in interface InsertableRelation

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object other)

Specified by:

equals in interface scala.Equals

Overrides:

equals in class Object