public abstract class SQLImplicits
extends java.lang.Object
DataFrame
s.
Constructor and Description |
---|
SQLImplicits() |
Modifier and Type | Method and Description |
---|---|
protected abstract SQLContext |
_sqlContext() |
DataFrameHolder |
intRddToDataFrameHolder(RDD<java.lang.Object> data)
Creates a single column DataFrame from an RDD[Int].
|
<A extends scala.Product> |
localSeqToDataFrameHolder(scala.collection.Seq<A> data,
scala.reflect.api.TypeTags.TypeTag<A> evidence$5)
Creates a DataFrame from a local Seq of Product.
|
<T> DatasetHolder<T> |
localSeqToDatasetHolder(scala.collection.Seq<T> s,
Encoder<T> evidence$3)
Creates a
Dataset from a local Seq. |
DataFrameHolder |
longRddToDataFrameHolder(RDD<java.lang.Object> data)
Creates a single column DataFrame from an RDD[Long].
|
Encoder<java.lang.Object> |
newBooleanEncoder() |
Encoder<java.lang.Object> |
newByteEncoder() |
Encoder<java.lang.Object> |
newDoubleEncoder() |
Encoder<java.lang.Object> |
newFloatEncoder() |
Encoder<java.lang.Object> |
newIntEncoder() |
Encoder<java.lang.Object> |
newLongEncoder() |
<T extends scala.Product> |
newProductEncoder(scala.reflect.api.TypeTags.TypeTag<T> evidence$1) |
Encoder<java.lang.Object> |
newShortEncoder() |
Encoder<java.lang.String> |
newStringEncoder() |
<A extends scala.Product> |
rddToDataFrameHolder(RDD<A> rdd,
scala.reflect.api.TypeTags.TypeTag<A> evidence$4)
Creates a DataFrame from an RDD of Product (e.g.
|
<T> DatasetHolder<T> |
rddToDatasetHolder(RDD<T> rdd,
Encoder<T> evidence$2)
Creates a
Dataset from an RDD. |
DataFrameHolder |
stringRddToDataFrameHolder(RDD<java.lang.String> data)
Creates a single column DataFrame from an RDD[String].
|
ColumnName |
symbolToColumn(scala.Symbol s)
An implicit conversion that turns a Scala
Symbol into a Column . |
protected abstract SQLContext _sqlContext()
public <T extends scala.Product> Encoder<T> newProductEncoder(scala.reflect.api.TypeTags.TypeTag<T> evidence$1)
public Encoder<java.lang.Object> newIntEncoder()
public Encoder<java.lang.Object> newLongEncoder()
public Encoder<java.lang.Object> newDoubleEncoder()
public Encoder<java.lang.Object> newFloatEncoder()
public Encoder<java.lang.Object> newByteEncoder()
public Encoder<java.lang.Object> newShortEncoder()
public Encoder<java.lang.Object> newBooleanEncoder()
public Encoder<java.lang.String> newStringEncoder()
public <T> DatasetHolder<T> rddToDatasetHolder(RDD<T> rdd, Encoder<T> evidence$2)
Dataset
from an RDD.rdd
- (undocumented)evidence$2
- (undocumented)public <T> DatasetHolder<T> localSeqToDatasetHolder(scala.collection.Seq<T> s, Encoder<T> evidence$3)
Dataset
from a local Seq.s
- (undocumented)evidence$3
- (undocumented)public ColumnName symbolToColumn(scala.Symbol s)
Symbol
into a Column
.s
- (undocumented)public <A extends scala.Product> DataFrameHolder rddToDataFrameHolder(RDD<A> rdd, scala.reflect.api.TypeTags.TypeTag<A> evidence$4)
rdd
- (undocumented)evidence$4
- (undocumented)public <A extends scala.Product> DataFrameHolder localSeqToDataFrameHolder(scala.collection.Seq<A> data, scala.reflect.api.TypeTags.TypeTag<A> evidence$5)
data
- (undocumented)evidence$5
- (undocumented)public DataFrameHolder intRddToDataFrameHolder(RDD<java.lang.Object> data)
data
- (undocumented)public DataFrameHolder longRddToDataFrameHolder(RDD<java.lang.Object> data)
data
- (undocumented)public DataFrameHolder stringRddToDataFrameHolder(RDD<java.lang.String> data)
data
- (undocumented)