Package org.apache.spark.sql.connector.expressions

Class LogicalExpressions

Object

org.apache.spark.sql.connector.expressions.LogicalExpressions

public class LogicalExpressions
extends Object

Helper methods for working with the logical expressions API.

Factory methods can be used when referencing the logical expression nodes is ambiguous because logical and internal expressions are used.

Constructor Summary

Constructors

Constructor	Description
LogicalExpressions()

Method Summary

Modifier and Type	Method	Description
static Transform	apply(String name, scala.collection.immutable.Seq<Expression> arguments)
static org.apache.spark.sql.connector.expressions.BucketTransform	bucket(int numBuckets, NamedReference[] references)
static org.apache.spark.sql.connector.expressions.SortedBucketTransform	bucket(int numBuckets, NamedReference[] references, NamedReference[] sortedCols)
static ClusterByTransform	clusterBy(NamedReference[] references)
static org.apache.spark.sql.connector.expressions.DaysTransform	days(NamedReference reference)
static org.apache.spark.sql.connector.expressions.HoursTransform	hours(NamedReference reference)
static org.apache.spark.sql.connector.expressions.IdentityTransform	identity(NamedReference reference)
static <T> org.apache.spark.sql.connector.expressions.LiteralValue<T>	literal(T value)
static <T> org.apache.spark.sql.connector.expressions.LiteralValue<T>	literal(T value, DataType dataType)
static org.apache.spark.sql.connector.expressions.MonthsTransform	months(NamedReference reference)
static NamedReference	parseReference(String name)
static NamedReference	reference(scala.collection.immutable.Seq<String> nameParts)
static SortOrder	sort(Expression reference, SortDirection direction, NullOrdering nullOrdering)
static org.apache.spark.sql.connector.expressions.YearsTransform	years(NamedReference reference)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

LogicalExpressions

public LogicalExpressions()

Method Details

literal

public static <T>
org.apache.spark.sql.connector.expressions.LiteralValue<T> literal(T value)

literal

public static <T>
org.apache.spark.sql.connector.expressions.LiteralValue<T> literal(T value,
 DataType dataType)

parseReference

public static NamedReference parseReference(String name)

reference

public static NamedReference reference(scala.collection.immutable.Seq<String> nameParts)

apply

public static Transform apply(String name,
 scala.collection.immutable.Seq<Expression> arguments)

bucket

public static org.apache.spark.sql.connector.expressions.BucketTransform bucket(int numBuckets,
 NamedReference[] references)

bucket

public static org.apache.spark.sql.connector.expressions.SortedBucketTransform bucket(int numBuckets,
 NamedReference[] references,
 NamedReference[] sortedCols)

clusterBy

public static ClusterByTransform clusterBy(NamedReference[] references)

identity

public static org.apache.spark.sql.connector.expressions.IdentityTransform identity(NamedReference reference)

years

public static org.apache.spark.sql.connector.expressions.YearsTransform years(NamedReference reference)

months

public static org.apache.spark.sql.connector.expressions.MonthsTransform months(NamedReference reference)

days

public static org.apache.spark.sql.connector.expressions.DaysTransform days(NamedReference reference)

hours

public static org.apache.spark.sql.connector.expressions.HoursTransform hours(NamedReference reference)

sort

public static SortOrder sort(Expression reference,
 SortDirection direction,
 NullOrdering nullOrdering)