You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by af...@apache.org on 2024/12/20 13:41:30 UTC
(flink) branch release-1.19 updated: [FLINK-33117][table][docs] Fix scala example in udfs page (#23439)
This is an automated email from the ASF dual-hosted git repository.
afedulov pushed a commit to branch release-1.19
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.19 by this push:
new 2eda53aa54e [FLINK-33117][table][docs] Fix scala example in udfs page (#23439)
2eda53aa54e is described below
commit 2eda53aa54eeecf6efa4d103595aa51a4f91de65
Author: CuiYanxiang <40...@users.noreply.github.com>
AuthorDate: Wed Dec 18 02:53:27 2024 +0800
[FLINK-33117][table][docs] Fix scala example in udfs page (#23439)
Co-authored-by: ‘cuiyanxiang’ <‘cyxiang123@163.com’>
---
docs/content.zh/docs/dev/table/functions/udfs.md | 10 +++++-----
docs/content/docs/dev/table/functions/udfs.md | 10 +++++-----
2 files changed, 10 insertions(+), 10 deletions(-)
diff --git a/docs/content.zh/docs/dev/table/functions/udfs.md b/docs/content.zh/docs/dev/table/functions/udfs.md
index f137b2ba446..602616b3e37 100644
--- a/docs/content.zh/docs/dev/table/functions/udfs.md
+++ b/docs/content.zh/docs/dev/table/functions/udfs.md
@@ -410,19 +410,19 @@ class OverloadedFunction extends ScalarFunction {
// 定义 decimal 的精度和小数位
@DataTypeHint("DECIMAL(12, 3)")
- def eval(double a, double b): BigDecimal = {
- java.lang.BigDecimal.valueOf(a + b)
+ def eval(a: Double, b: Double): BigDecimal = {
+ BigDecimal(a + b)
}
// 定义嵌套数据类型
@DataTypeHint("ROW<s STRING, t TIMESTAMP_LTZ(3)>")
- def eval(Int i): Row = {
- Row.of(java.lang.String.valueOf(i), java.time.Instant.ofEpochSecond(i))
+ def eval(i: Int): Row = {
+ Row.of(i.toString, java.time.Instant.ofEpochSecond(i))
}
// 允许任意类型的符入,并输出定制序列化后的值
@DataTypeHint(value = "RAW", bridgedTo = classOf[java.nio.ByteBuffer])
- def eval(@DataTypeHint(inputGroup = InputGroup.ANY) Object o): java.nio.ByteBuffer = {
+ def eval(@DataTypeHint(inputGroup = InputGroup.ANY) o: Any): java.nio.ByteBuffer = {
MyUtils.serializeToByteBuffer(o)
}
}
diff --git a/docs/content/docs/dev/table/functions/udfs.md b/docs/content/docs/dev/table/functions/udfs.md
index 1b824387941..9e44707526a 100644
--- a/docs/content/docs/dev/table/functions/udfs.md
+++ b/docs/content/docs/dev/table/functions/udfs.md
@@ -415,19 +415,19 @@ class OverloadedFunction extends ScalarFunction {
// define the precision and scale of a decimal
@DataTypeHint("DECIMAL(12, 3)")
- def eval(double a, double b): BigDecimal = {
- java.lang.BigDecimal.valueOf(a + b)
+ def eval(a: Double, b: Double): BigDecimal = {
+ BigDecimal(a + b)
}
// define a nested data type
@DataTypeHint("ROW<s STRING, t TIMESTAMP_LTZ(3)>")
- def eval(Int i): Row = {
- Row.of(java.lang.String.valueOf(i), java.time.Instant.ofEpochSecond(i))
+ def eval(i: Int): Row = {
+ Row.of(i.toString, java.time.Instant.ofEpochSecond(i))
}
// allow wildcard input and customly serialized output
@DataTypeHint(value = "RAW", bridgedTo = classOf[java.nio.ByteBuffer])
- def eval(@DataTypeHint(inputGroup = InputGroup.ANY) Object o): java.nio.ByteBuffer = {
+ def eval(@DataTypeHint(inputGroup = InputGroup.ANY) o: Any): java.nio.ByteBuffer = {
MyUtils.serializeToByteBuffer(o)
}
}