org.apache.spark.sql.json

Class JSONRelation

Object

org.apache.spark.sql.sources.BaseRelation

org.apache.spark.sql.sources.TableScan

org.apache.spark.sql.json.JSONRelation

All Implemented Interfaces:

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

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
JSONRelation(String fileName, double samplingRatio, SQLContext sqlContext)

Method Summary

Methods

Modifier and Type	Method and Description
RDD<org.apache.spark.sql.catalyst.expressions.Row>	buildScan()
String	fileName()
double	samplingRatio()
org.apache.spark.sql.catalyst.types.StructType	schema()
SQLContext	sqlContext()

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

sizeInBytes

Methods inherited from class Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

JSONRelation

public JSONRelation(String fileName,
            double samplingRatio,
            SQLContext sqlContext)

Method Detail

fileName

public String fileName()

samplingRatio

public double samplingRatio()

sqlContext

public SQLContext sqlContext()

Specified by:

sqlContext in class BaseRelation

schema

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

Specified by:

schema in class BaseRelation

buildScan

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

Specified by:

buildScan in class TableScan