public class LogicalExpressions
extends Object
Factory methods can be used when referencing the logical expression nodes is ambiguous because logical and internal expressions are used.
Constructor and Description |
---|
LogicalExpressions() |
Modifier and Type | Method and Description |
---|---|
static Transform |
apply(String name,
scala.collection.Seq<Expression> arguments) |
static org.apache.spark.sql.connector.expressions.BucketTransform |
bucket(int numBuckets,
scala.collection.Seq<String> columns) |
static org.apache.spark.sql.connector.expressions.DaysTransform |
days(String column) |
static org.apache.spark.sql.connector.expressions.HoursTransform |
hours(String column) |
static org.apache.spark.sql.connector.expressions.IdentityTransform |
identity(String column) |
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(String column) |
static NamedReference |
reference(String name) |
static org.apache.spark.sql.connector.expressions.YearsTransform |
years(String column) |
public static <T> org.apache.spark.sql.connector.expressions.LiteralValue<T> literal(T value)
public static <T> org.apache.spark.sql.connector.expressions.LiteralValue<T> literal(T value, DataType dataType)
public static NamedReference reference(String name)
public static Transform apply(String name, scala.collection.Seq<Expression> arguments)
public static org.apache.spark.sql.connector.expressions.BucketTransform bucket(int numBuckets, scala.collection.Seq<String> columns)
public static org.apache.spark.sql.connector.expressions.IdentityTransform identity(String column)
public static org.apache.spark.sql.connector.expressions.YearsTransform years(String column)
public static org.apache.spark.sql.connector.expressions.MonthsTransform months(String column)
public static org.apache.spark.sql.connector.expressions.DaysTransform days(String column)
public static org.apache.spark.sql.connector.expressions.HoursTransform hours(String column)