Class IcebergSpark

java.lang.Object
org.apache.iceberg.spark.IcebergSpark

public class IcebergSpark extends Object
  • Method Details

    • registerBucketUDF

      public static void registerBucketUDF(org.apache.spark.sql.SparkSession session, String funcName, org.apache.spark.sql.types.DataType sourceType, int numBuckets)
    • registerTruncateUDF

      public static void registerTruncateUDF(org.apache.spark.sql.SparkSession session, String funcName, org.apache.spark.sql.types.DataType sourceType, int width)