Package org.apache.spark.sql

Class functions.partitioning$

Object
org.apache.spark.sql.functions.partitioning$
Enclosing class:
functions
public static class functions.partitioning$ extends Object

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    static final functions.partitioning$
    MODULE$
    Static reference to the singleton instance of this Scala object.

  • Constructor Summary

    Constructors
    Constructor
    Description
    partitioning$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    Column
    bucket(int numBuckets, Column e)
    (Scala-specific) A transform for any type that partitions by a hash of the input column.
    Column
    bucket(Column numBuckets, Column e)
    (Scala-specific) A transform for any type that partitions by a hash of the input column.
    Column
    days(Column e)
    (Scala-specific) A transform for timestamps and dates to partition data into days.
    Column
    hours(Column e)
    (Scala-specific) A transform for timestamps to partition data into hours.
    Column
    months(Column e)
    (Scala-specific) A transform for timestamps and dates to partition data into months.
    Column
    years(Column e)
    (Scala-specific) A transform for timestamps and dates to partition data into years.

    Methods inherited from class java.lang.Object

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

  • Field Details

    • MODULE$

      public static final functions.partitioning$ MODULE$
      Static reference to the singleton instance of this Scala object.

  • Constructor Details

    • partitioning$

      public partitioning$()

  • Method Details

    • years

      public Column years(Column e)
      (Scala-specific) A transform for timestamps and dates to partition data into years.

      Parameters:
      e - (undocumented)
      Returns:
      (undocumented)
      Since:
      4.0.0

    • months

      public Column months(Column e)
      (Scala-specific) A transform for timestamps and dates to partition data into months.

      Parameters:
      e - (undocumented)
      Returns:
      (undocumented)
      Since:
      4.0.0

    • days

      public Column days(Column e)
      (Scala-specific) A transform for timestamps and dates to partition data into days.

      Parameters:
      e - (undocumented)
      Returns:
      (undocumented)
      Since:
      4.0.0

    • hours

      public Column hours(Column e)
      (Scala-specific) A transform for timestamps to partition data into hours.

      Parameters:
      e - (undocumented)
      Returns:
      (undocumented)
      Since:
      4.0.0

    • bucket

      public Column bucket(Column numBuckets, Column e)
      (Scala-specific) A transform for any type that partitions by a hash of the input column.

      Parameters:
      numBuckets - (undocumented)
      e - (undocumented)
      Returns:
      (undocumented)
      Since:
      4.0.0

    • bucket

      public Column bucket(int numBuckets, Column e)
      (Scala-specific) A transform for any type that partitions by a hash of the input column.

      Parameters:
      numBuckets - (undocumented)
      e - (undocumented)
      Returns:
      (undocumented)
      Since:
      4.0.0