Package org.apache.iceberg.spark
Class IcebergSpark
java.lang.Object
org.apache.iceberg.spark.IcebergSpark
-
Method Summary
Modifier and TypeMethodDescriptionstatic void
registerBucketUDF
(org.apache.spark.sql.SparkSession session, String funcName, org.apache.spark.sql.types.DataType sourceType, int numBuckets) static void
registerTruncateUDF
(org.apache.spark.sql.SparkSession session, String funcName, org.apache.spark.sql.types.DataType sourceType, int width)
-
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)
-