Package org.apache.iceberg.spark.functions

Class TruncateFunction

java.lang.Object

org.apache.iceberg.spark.functions.TruncateFunction

All Implemented Interfaces:

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

public class TruncateFunction
extends Object
implements org.apache.spark.sql.connector.catalog.functions.UnboundFunction

A Spark function implementation for the Iceberg truncate transform.

Example usage: SELECT system.truncate(1, 'abc'), which returns the String 'a'.

Note that for performance reasons, the given input width is not validated in the implementations used in code-gen. The width must remain non-negative to give meaningful results.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TruncateFunction.TruncateBase<T>
static class	TruncateFunction.TruncateBigInt
static class	TruncateFunction.TruncateBinary
static class	TruncateFunction.TruncateDecimal
static class	TruncateFunction.TruncateInt
static class	TruncateFunction.TruncateSmallInt
static class	TruncateFunction.TruncateString
static class	TruncateFunction.TruncateTinyInt

Constructor Summary

Constructors

Constructor	Description
TruncateFunction()

Method Summary

Modifier and Type	Method	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 Details

TruncateFunction

public TruncateFunction()

Method Details

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