Package org.apache.spark.sql

Class TypedColumn<T,U>

Object

org.apache.spark.sql.Column

org.apache.spark.sql.TypedColumn<T,U>

All Implemented Interfaces:

org.apache.spark.internal.Logging, org.apache.spark.sql.internal.TableValuedFunctionArgument

public class TypedColumn<T,U>
extends Column

A Column where an Encoder has been given for the expected input and return type. To create a TypedColumn, use the as function on a Column.

Since:

1.6.0

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.spark.internal.Logging

org.apache.spark.internal.Logging.LogStringContext, org.apache.spark.internal.Logging.SparkShellLoggingFilter

Constructor Summary

Constructors

Constructor	Description
TypedColumn(org.apache.spark.sql.internal.ColumnNode node, Encoder<U> encoder)

Method Summary

Modifier and Type	Method	Description
TypedColumn<T,U>	name(String alias)	Gives the TypedColumn a name (alias).

Methods inherited from class org.apache.spark.sql.Column

alias, and, apply, as, as, as, as, as, as, asc, asc_nulls_first, asc_nulls_last, between, bitwiseAND, bitwiseOR, bitwiseXOR, cast, cast, contains, desc, desc_nulls_first, desc_nulls_last, divide, dropFields, endsWith, endsWith, eqNullSafe, equals, equalTo, explain, geq, getField, getItem, gt, hashCode, ilike, isin, isin, isInCollection, isInCollection, isNaN, isNotNull, isNull, leq, like, lt, minus, mod, multiply, node, notEqual, or, otherwise, outer, over, over, plus, rlike, startsWith, startsWith, substr, substr, toString, try_cast, try_cast, when, withField

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.spark.internal.Logging

initializeForcefully, initializeLogIfNecessary, initializeLogIfNecessary, initializeLogIfNecessary$default$2, isTraceEnabled, log, logDebug, logDebug, logDebug, logDebug, logError, logError, logError, logError, logInfo, logInfo, logInfo, logInfo, logName, LogStringContext, logTrace, logTrace, logTrace, logTrace, logWarning, logWarning, logWarning, logWarning, org$apache$spark$internal$Logging$$log_, org$apache$spark$internal$Logging$$log__$eq, withLogContext

Constructor Details

TypedColumn

public TypedColumn(org.apache.spark.sql.internal.ColumnNode node,
 Encoder<U> encoder)

Method Details

name

public TypedColumn<T,U> name(String alias)

Gives the TypedColumn a name (alias). If the current TypedColumn has metadata associated with it, this metadata will be propagated to the new column.

Overrides:

name in class Column

Parameters:

alias - (undocumented)

Returns:

(undocumented)

Since:

2.0.0