Package org.apache.spark.sql.sources

Class EqualNullSafe

Object
org.apache.spark.sql.sources.Filter
org.apache.spark.sql.sources.EqualNullSafe
All Implemented Interfaces:
Serializable, scala.Equals, scala.Product
public class EqualNullSafe extends Filter implements scala.Product, Serializable
Performs equality comparison, similar to EqualTo. However, this differs from EqualTo in that it returns true (rather than NULL) if both inputs are NULL, and false (rather than NULL) if one of the input is NULL and the other is not NULL.

param: attribute of the column to be evaluated; dots are used as separators for nested columns. If any part of the names contains dots, it is quoted to avoid confusion.

Since:
1.5.0
See Also:

  • Constructor Details

    • EqualNullSafe

      public EqualNullSafe(String attribute, Object value)

  • Method Details

    • apply

      public abstract static R apply(T1 v1, T2 v2)

    • toString

      public static String toString()

    • attribute

      public String attribute()

    • value

      public Object value()

    • references

      public String[] references()
      Description copied from class: Filter
      List of columns that are referenced by this filter.

      Note that, each element in references represents a column. The column name follows ANSI SQL names and identifiers: dots are used as separators for nested columns, name will be quoted if it contains special chars.

      Specified by:
      references in class Filter
      Returns:
      (undocumented)

    • toV2

      public Predicate toV2()