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 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)