TypedColumn

TypedColumn is a Column with the ExpressionEncoder for the types of the input and the output.

TypedColumn is created using as operator on a Column.

scala> val id = $"id".as[Int]
id: org.apache.spark.sql.TypedColumn[Any,Int] = id

scala> id.expr
res1: org.apache.spark.sql.catalyst.expressions.Expression = 'id

name Operator

name(alias: String): TypedColumn[T, U]
Note
 name is part of Column Contract to…​FIXME.

name…​FIXME

Note
 name is used when…​FIXME

Creating TypedColumn — withInputType Internal Method

withInputType(
  inputEncoder: ExpressionEncoder[_],
  inputAttributes: Seq[Attribute]): TypedColumn[T, U]

withInputType…​FIXME

Note

withInputType is used when the following typed operators are used:

Creating TypedColumn Instance

TypedColumn takes the following when created:

TypedColumn initializes the internal registries and counters.

results matching ""

    No results matching ""