From df1688d1de053ab726a8d13f16d4b5e40bb7368d Mon Sep 17 00:00:00 2001 From: emptyOVO Date: Mon, 9 Sep 2024 22:44:59 +0800 Subject: [PATCH] fix: update function logic --- .../sdk/transform/process/function/RandIntegerFunction.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/RandIntegerFunction.java b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/RandIntegerFunction.java index 80c1046ed9..446d4aca58 100644 --- a/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/RandIntegerFunction.java +++ b/inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/RandIntegerFunction.java @@ -31,7 +31,7 @@ /** * RandIntegerFunction * description: RAND_INTEGER(INT1)--Returns a pseudorandom integer value in the range [0, INT) - * RAND_INTEGER(INT1, INT2)--Returns a pseudorandom integer value in the range [0, INT2) with an initial seed INT1. + * RAND_INTEGER(INT1, INT2)--Returns a pseudorandom integer value in the range [0, INT1) with an initial seed INT2. * Two RAND_INTEGER functions will return idential sequences of numbers if they have the same initial seed and bound. */ @TransformFunction(names = {"rand_integer"}) @@ -69,7 +69,7 @@ private int randInteger(int range) { return random.nextInt(range); } - private int randInteger(int seed, int range) { + private int randInteger(int range, int seed) { random.setSeed(seed); return random.nextInt(range); }