abstract class SQLImplicits extends LowPrioritySQLImplicits
A collection of implicit methods for converting common Scala objects into Datasets.
- Source
- SQLImplicits.scala
- Since
1.6.0
- Alphabetic
- By Inheritance
- SQLImplicits
- LowPrioritySQLImplicits
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new SQLImplicits()
Type Members
- implicit class StringToColumn extends AnyRef
Converts $"col name" into a Column.
Converts $"col name" into a Column.
- Since
2.0.0
Abstract Value Members
- abstract def session: SparkSession
- Attributes
- protected
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- implicit def localSeqToDatasetHolder[T](s: Seq[T])(implicit arg0: Encoder[T]): DatasetHolder[T]
Creates a Dataset from a local Seq.
Creates a Dataset from a local Seq.
- Since
1.6.0
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- implicit def newBooleanArrayEncoder: Encoder[Array[Boolean]]
- Since
1.6.1
- implicit def newBooleanEncoder: Encoder[Boolean]
- Since
1.6.0
- implicit def newBoxedBooleanEncoder: Encoder[Boolean]
- Since
2.0.0
- implicit def newBoxedByteEncoder: Encoder[Byte]
- Since
2.0.0
- implicit def newBoxedDoubleEncoder: Encoder[Double]
- Since
2.0.0
- implicit def newBoxedFloatEncoder: Encoder[Float]
- Since
2.0.0
- implicit def newBoxedIntEncoder: Encoder[Integer]
- Since
2.0.0
- implicit def newBoxedLongEncoder: Encoder[Long]
- Since
2.0.0
- implicit def newBoxedShortEncoder: Encoder[Short]
- Since
2.0.0
- implicit def newByteArrayEncoder: Encoder[Array[Byte]]
- Since
1.6.1
- implicit def newByteEncoder: Encoder[Byte]
- Since
1.6.0
- implicit def newDateEncoder: Encoder[Date]
- Since
2.2.0
- implicit def newDoubleArrayEncoder: Encoder[Array[Double]]
- Since
1.6.1
- implicit def newDoubleEncoder: Encoder[Double]
- Since
1.6.0
- implicit def newDurationEncoder: Encoder[Duration]
- Since
3.2.0
- implicit def newFloatArrayEncoder: Encoder[Array[Float]]
- Since
1.6.1
- implicit def newFloatEncoder: Encoder[Float]
- Since
1.6.0
- implicit def newInstantEncoder: Encoder[Instant]
- Since
3.0.0
- implicit def newIntArrayEncoder: Encoder[Array[Int]]
- Since
1.6.1
- implicit def newIntEncoder: Encoder[Int]
- Since
1.6.0
- implicit def newJavaDecimalEncoder: Encoder[BigDecimal]
- Since
2.2.0
- implicit def newJavaEnumEncoder[A <: Enum[_]](implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): Encoder[A]
- Since
3.2.0
- implicit def newLocalDateEncoder: Encoder[LocalDate]
- Since
3.0.0
- implicit def newLocalDateTimeEncoder: Encoder[LocalDateTime]
- Since
3.4.0
- implicit def newLongArrayEncoder: Encoder[Array[Long]]
- Since
1.6.1
- implicit def newLongEncoder: Encoder[Long]
- Since
1.6.0
- implicit def newMapEncoder[T <: Map[_, _]](implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T]): Encoder[T]
- Since
2.3.0
- implicit def newPeriodEncoder: Encoder[Period]
- Since
3.2.0
- implicit def newProductArrayEncoder[A <: Product](implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): Encoder[Array[A]]
- Since
1.6.1
- implicit def newProductEncoder[T <: Product](implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T]): Encoder[T]
- Definition Classes
- LowPrioritySQLImplicits
- Since
1.6.0
- implicit def newScalaDecimalEncoder: Encoder[BigDecimal]
- Since
2.2.0
- implicit def newSequenceEncoder[T <: Seq[_]](implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T]): Encoder[T]
- Since
2.2.0
- implicit def newSetEncoder[T <: Set[_]](implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[T]): Encoder[T]
Notice that we serialize
Set
to Catalyst array.Notice that we serialize
Set
to Catalyst array. The set property is only kept when manipulating the domain objects. The serialization format doesn't keep the set property. When we have a Catalyst array which contains duplicated elements and convert it toDataset[Set[T]]
by using the encoder, the elements will be de-duplicated.- Since
2.3.0
- implicit def newShortArrayEncoder: Encoder[Array[Short]]
- Since
1.6.1
- implicit def newShortEncoder: Encoder[Short]
- Since
1.6.0
- implicit def newStringArrayEncoder: Encoder[Array[String]]
- Since
1.6.1
- implicit def newStringEncoder: Encoder[String]
- Since
1.6.0
- implicit def newTimeStampEncoder: Encoder[Timestamp]
- Since
2.2.0
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- implicit def rddToDatasetHolder[T](rdd: RDD[T])(implicit arg0: Encoder[T]): DatasetHolder[T]
Creates a Dataset from an RDD.
Creates a Dataset from an RDD.
- Since
1.6.0
- implicit def symbolToColumn(s: Symbol): ColumnName
An implicit conversion that turns a Scala
Symbol
into a Column.An implicit conversion that turns a Scala
Symbol
into a Column.- Since
1.3.0
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)
- def newBooleanSeqEncoder: Encoder[Seq[Boolean]]
- Annotations
- @deprecated
- Deprecated
(Since version 2.2.0) Use newSequenceEncoder instead
- Since
1.6.1
- def newByteSeqEncoder: Encoder[Seq[Byte]]
- Annotations
- @deprecated
- Deprecated
(Since version 2.2.0) Use newSequenceEncoder instead
- Since
1.6.1
- def newDoubleSeqEncoder: Encoder[Seq[Double]]
- Annotations
- @deprecated
- Deprecated
(Since version 2.2.0) Use newSequenceEncoder instead
- Since
1.6.1
- def newFloatSeqEncoder: Encoder[Seq[Float]]
- Annotations
- @deprecated
- Deprecated
(Since version 2.2.0) Use newSequenceEncoder instead
- Since
1.6.1
- def newIntSeqEncoder: Encoder[Seq[Int]]
- Annotations
- @deprecated
- Deprecated
(Since version 2.2.0) Use newSequenceEncoder instead
- Since
1.6.1
- def newLongSeqEncoder: Encoder[Seq[Long]]
- Annotations
- @deprecated
- Deprecated
(Since version 2.2.0) Use newSequenceEncoder instead
- Since
1.6.1
- def newProductSeqEncoder[A <: Product](implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): Encoder[Seq[A]]
- Annotations
- @deprecated
- Deprecated
(Since version 2.2.0) Use newSequenceEncoder instead
- Since
1.6.1
- def newShortSeqEncoder: Encoder[Seq[Short]]
- Annotations
- @deprecated
- Deprecated
(Since version 2.2.0) Use newSequenceEncoder instead
- Since
1.6.1
- def newStringSeqEncoder: Encoder[Seq[String]]
- Annotations
- @deprecated
- Deprecated
(Since version 2.2.0) Use newSequenceEncoder instead
- Since
1.6.1