public static class HoursFunction.TimestampToHoursFunction
extends java.lang.Object
implements org.apache.spark.sql.connector.catalog.functions.ScalarFunction<java.lang.Integer>
Constructor and Description |
---|
TimestampToHoursFunction() |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
canonicalName() |
org.apache.spark.sql.types.DataType[] |
inputTypes() |
static int |
invoke(long micros) |
java.lang.String |
name() |
java.lang.Integer |
produceResult(org.apache.spark.sql.catalyst.InternalRow input) |
org.apache.spark.sql.types.DataType |
resultType() |
public static int invoke(long micros)
public java.lang.String name()
name
in interface org.apache.spark.sql.connector.catalog.functions.Function
public org.apache.spark.sql.types.DataType[] inputTypes()
inputTypes
in interface org.apache.spark.sql.connector.catalog.functions.BoundFunction
public org.apache.spark.sql.types.DataType resultType()
resultType
in interface org.apache.spark.sql.connector.catalog.functions.BoundFunction
public java.lang.String canonicalName()
canonicalName
in interface org.apache.spark.sql.connector.catalog.functions.BoundFunction
public java.lang.Integer produceResult(org.apache.spark.sql.catalyst.InternalRow input)
produceResult
in interface org.apache.spark.sql.connector.catalog.functions.ScalarFunction<java.lang.Integer>