public class IcebergSpark
extends java.lang.Object
Modifier and Type | Method and Description |
---|---|
static void |
registerBucketUDF(org.apache.spark.sql.SparkSession session,
java.lang.String funcName,
org.apache.spark.sql.types.DataType sourceType,
int numBuckets) |
static void |
registerTruncateUDF(org.apache.spark.sql.SparkSession session,
java.lang.String funcName,
org.apache.spark.sql.types.DataType sourceType,
int width) |
public static void registerBucketUDF(org.apache.spark.sql.SparkSession session, java.lang.String funcName, org.apache.spark.sql.types.DataType sourceType, int numBuckets)
public static void registerTruncateUDF(org.apache.spark.sql.SparkSession session, java.lang.String funcName, org.apache.spark.sql.types.DataType sourceType, int width)