org.apache.paimon.spark.catalog.functions

Class PaimonFunctions.BucketFunction

java.lang.Object

org.apache.paimon.spark.catalog.functions.PaimonFunctions.BucketFunction

All Implemented Interfaces:

Serializable, org.apache.spark.sql.connector.catalog.functions.Function, org.apache.spark.sql.connector.catalog.functions.UnboundFunction

Enclosing class:

PaimonFunctions

public static class PaimonFunctions.BucketFunction
extends Object
implements org.apache.spark.sql.connector.catalog.functions.UnboundFunction

For now, we only support report bucket partitioning for table scan. So the case `SELECT bucket(10, col)` would fail since we do not implement ScalarFunction

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
BucketFunction()

Method Summary

Modifier and Type	Method and Description
org.apache.spark.sql.connector.catalog.functions.BoundFunction	bind(org.apache.spark.sql.types.StructType inputType)
String	description()
String	name()

Methods inherited from class java.lang.Object

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

Constructor Detail

BucketFunction

public BucketFunction()

Method Detail

bind

public org.apache.spark.sql.connector.catalog.functions.BoundFunction bind(org.apache.spark.sql.types.StructType inputType)

Specified by:

bind in interface org.apache.spark.sql.connector.catalog.functions.UnboundFunction

description

public String description()

Specified by:

description in interface org.apache.spark.sql.connector.catalog.functions.UnboundFunction

name

public String name()

Specified by:

name in interface org.apache.spark.sql.connector.catalog.functions.Function