Spark Connect for Scala 3
API
Generated with
Spark Connect for Scala 3/org.apache.spark/org.apache.spark.sql/Encoders

Encoders

org.apache.spark.sql.Encoders
object Encoders

Spark-conventional alias; re-exports the derived Encoder instances and factory.

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Self type
Encoders.type

Members list

Value members

Concrete methods

def BINARY: Encoder[Array[Byte]]
def BOOLEAN: Encoder[Boolean]
def BYTE: Encoder[Byte]
def DATE: Encoder[Date]
def DECIMAL: Encoder[BigDecimal]
def DOUBLE: Encoder[Double]
def DURATION: Encoder[Duration]
def FLOAT: Encoder[Float]
def INSTANT: Encoder[Instant]
def INT: Encoder[Integer]
def LOCALDATE: Encoder[LocalDate]
def LOCALDATETIME: Encoder[LocalDateTime]
def LOCALTIME: Encoder[LocalTime]
def LONG: Encoder[Long]
def PERIOD: Encoder[Period]
def SHORT: Encoder[Short]
def STRING: Encoder[String]
def TIMESTAMP: Encoder[Timestamp]
def product[T <: Product](using enc: Encoder[T]): Encoder[T]

The derived encoder of a case class or tuple T.

The derived encoder of a case class or tuple T.

Attributes

def row(schema: StructType): Encoder[Row]

An encoder for Rows of the given schema.

An encoder for Rows of the given schema.

Attributes

def scalaBoolean: Encoder[Boolean]
def scalaByte: Encoder[Byte]
def scalaDouble: Encoder[Double]
def scalaFloat: Encoder[Float]
def scalaInt: Encoder[Int]
def scalaLong: Encoder[Long]
def scalaShort: Encoder[Short]
def tuple[T1](e1: Encoder[T1]): Encoder[Tuple1[T1]]
def tuple[T1, T2](e1: Encoder[T1], e2: Encoder[T2]): Encoder[(T1, T2)]
def tuple[T1, T2, T3](e1: Encoder[T1], e2: Encoder[T2], e3: Encoder[T3]): Encoder[(T1, T2, T3)]
def tuple[T1, T2, T3, T4](e1: Encoder[T1], e2: Encoder[T2], e3: Encoder[T3], e4: Encoder[T4]): Encoder[(T1, T2, T3, T4)]
def tuple[T1, T2, T3, T4, T5](e1: Encoder[T1], e2: Encoder[T2], e3: Encoder[T3], e4: Encoder[T4], e5: Encoder[T5]): Encoder[(T1, T2, T3, T4, T5)]

Exports

Defined exports

def apply[T](using e: Encoder[T]): Encoder[T]
Exported from Encoder
private[sql] val rowEncoder: Encoder[Row]
Exported from Encoder

Identity encoder used for Dataset[Row] (DataFrames).

Identity encoder used for Dataset[Row] (DataFrames).

Attributes

Generated with