org.apache.spark.sql

Class ColumnName

Object

org.apache.spark.sql.Column

org.apache.spark.sql.ColumnName

All Implemented Interfaces:

Logging

public class ColumnName
extends Column

A convenient class used for constructing schema.

Since:

1.3.0

Constructor Summary

Constructors

Constructor and Description
ColumnName(String name)

Method Summary

Modifier and Type	Method and Description
StructField	array(DataType dataType) Creates a new StructField of type array.
StructField	binary() Creates a new StructField of type binary.
StructField	date() Creates a new StructField of type date.
StructField	decimal() Creates a new StructField of type decimal.
StructField	decimal(int precision, int scale) Creates a new StructField of type decimal.
StructField	map(DataType keyType, DataType valueType) Creates a new StructField of type map.
StructField	map(MapType mapType)
StructField	string() Creates a new StructField of type string.
StructField	struct(scala.collection.Seq<StructField> fields) Creates a new StructField of type struct.
StructField	struct(StructType structType) Creates a new StructField of type struct.
StructField	timestamp() Creates a new StructField of type timestamp.

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

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

Methods inherited from class Object

getClass, notify, notifyAll, wait, wait, wait

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

initializeLogging, initializeLogIfNecessary, initializeLogIfNecessary, isTraceEnabled, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

ColumnName

public ColumnName(String name)

Method Detail

array

public StructField array(DataType dataType)

Creates a new StructField of type array.

Parameters:

dataType - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

binary

public StructField binary()

Creates a new StructField of type binary.

Returns:

(undocumented)

Since:

1.3.0

date

public StructField date()

Creates a new StructField of type date.

Returns:

(undocumented)

Since:

1.3.0

decimal

public StructField decimal()

Creates a new StructField of type decimal.

Returns:

(undocumented)

Since:

1.3.0

decimal

public StructField decimal(int precision,
                           int scale)

Creates a new StructField of type decimal.

Parameters:

precision - (undocumented)

scale - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

map

public StructField map(DataType keyType,
                       DataType valueType)

Creates a new StructField of type map.

Parameters:

keyType - (undocumented)

valueType - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

map

public StructField map(MapType mapType)

string

public StructField string()

Creates a new StructField of type string.

Returns:

(undocumented)

Since:

1.3.0

struct

public StructField struct(scala.collection.Seq<StructField> fields)

Creates a new StructField of type struct.

Parameters:

fields - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

struct

public StructField struct(StructType structType)

Creates a new StructField of type struct.

Parameters:

structType - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

timestamp

public StructField timestamp()

Creates a new StructField of type timestamp.

Returns:

(undocumented)

Since:

1.3.0