This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new 2ee04519aba fix scalar function args and return type problem
2ee04519aba is described below
commit 2ee04519aba01748ebae9478b8c72e257fb3986f
Author: linxt20 <[email protected]>
AuthorDate: Wed Aug 21 10:57:38 2024 +0800
fix scalar function args and return type problem
---
.../scalar/IoTDBScalarFunctionTableIT.java | 263 +++++++--------------
.../relational/ColumnTransformerBuilder.java | 32 +--
.../relational/metadata/TableMetadataImpl.java | 62 +++--
.../plan/relational/sql/parser/AstBuilder.java | 3 +-
.../column/unary/scalar/AcosColumnTransformer.java | 3 +-
.../column/unary/scalar/AsinColumnTransformer.java | 3 +-
.../column/unary/scalar/AtanColumnTransformer.java | 3 +-
.../column/unary/scalar/CeilColumnTransformer.java | 3 +-
.../column/unary/scalar/CosColumnTransformer.java | 3 +-
.../column/unary/scalar/CoshColumnTransformer.java | 3 +-
.../unary/scalar/DegreesColumnTransformer.java | 3 +-
.../column/unary/scalar/ExpColumnTransformer.java | 3 +-
.../unary/scalar/FloorColumnTransformer.java | 3 +-
.../column/unary/scalar/LnColumnTransformer.java | 3 +-
.../unary/scalar/Log10ColumnTransformer.java | 3 +-
.../unary/scalar/RadiansColumnTransformer.java | 3 +-
.../column/unary/scalar/SignColumnTransformer.java | 3 +-
.../column/unary/scalar/SinColumnTransformer.java | 3 +-
.../column/unary/scalar/SinhColumnTransformer.java | 3 +-
.../column/unary/scalar/SqrtColumnTransformer.java | 3 +-
.../column/unary/scalar/TanColumnTransformer.java | 3 +-
.../column/unary/scalar/TanhColumnTransformer.java | 3 +-
22 files changed, 153 insertions(+), 261 deletions(-)
diff --git
a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/builtinfunction/scalar/IoTDBScalarFunctionTableIT.java
b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/builtinfunction/scalar/IoTDBScalarFunctionTableIT.java
index 91aac5ee497..dd67aa726d1 100644
---
a/integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/builtinfunction/scalar/IoTDBScalarFunctionTableIT.java
+++
b/integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/builtinfunction/scalar/IoTDBScalarFunctionTableIT.java
@@ -60,8 +60,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO absTable(Time,device_id,s4) values(3, 'd1', -2.5)",
"INSERT INTO absTable(Time,device_id,s5) values(2, 'd1', -1.5)",
"INSERT INTO absTable(Time,device_id,s5) values(3, 'd1', -2.5)",
- "INSERT INTO absTable(Time,device_id,s8) values(2, 'd1', 1)",
- "INSERT INTO absTable(Time,device_id,s8) values(3, 'd1', 2)",
// acosSQL
"create table acosTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO acosTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'abcd', 1, 1, 1, 1, true, '2021-10-01', 1, 'abcd', X'abcd')",
@@ -69,7 +67,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO acosTable(Time,device_id,s3) values(2, 'd1', 2)",
"INSERT INTO acosTable(Time,device_id,s4) values(2, 'd1', 0.5)",
"INSERT INTO acosTable(Time,device_id,s5) values(2, 'd1', 0.5)",
- "INSERT INTO acosTable(Time,device_id,s8) values(2, 'd1', 2)",
// asinSQL
"create table asinTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO asinTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'abcd', 1, 1, 1, 1, true, '2021-10-01', 1, 'abcd', X'abcd')",
@@ -77,7 +74,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO asinTable(Time,device_id,s3) values(2, 'd1', 2)",
"INSERT INTO asinTable(Time,device_id,s4) values(2, 'd1', 0.5)",
"INSERT INTO asinTable(Time,device_id,s5) values(2, 'd1', 0.5)",
- "INSERT INTO asinTable(Time,device_id,s8) values(2, 'd1', 2)",
// atanSQL
"create table atanTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO atanTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'abcd',
X'abcd')",
@@ -89,8 +85,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO atanTable(Time,device_id,s4) values(3, 'd1', 3.5)",
"INSERT INTO atanTable(Time,device_id,s5) values(2, 'd1', 2.5)",
"INSERT INTO atanTable(Time,device_id,s5) values(3, 'd1', 3.5)",
- "INSERT INTO atanTable(Time,device_id,s8) values(2, 'd1', 2)",
- "INSERT INTO atanTable(Time,device_id,s8) values(3, 'd1', 3)",
// ceilSQL
"create table ceilTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO ceilTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'abcd',
X'abcd')",
@@ -102,8 +96,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO ceilTable(Time,device_id,s4) values(3, 'd1', -2.5)",
"INSERT INTO ceilTable(Time,device_id,s5) values(2, 'd1', 2.5)",
"INSERT INTO ceilTable(Time,device_id,s5) values(3, 'd1', -2.5)",
- "INSERT INTO ceilTable(Time,device_id,s8) values(2, 'd1', 2)",
- "INSERT INTO ceilTable(Time,device_id,s8) values(3, 'd1', 3)",
// concatSQL
"create table concatTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO
concatTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10) values(1, 'd1',
'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'ab', X'abcd')",
@@ -124,8 +116,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO cosTable(Time,device_id,s4) values(3, 'd1', 3.5)",
"INSERT INTO cosTable(Time,device_id,s5) values(2, 'd1', 2.5)",
"INSERT INTO cosTable(Time,device_id,s5) values(3, 'd1', 3.5)",
- "INSERT INTO cosTable(Time,device_id,s8) values(2, 'd1', 2)",
- "INSERT INTO cosTable(Time,device_id,s8) values(3, 'd1', 3)",
// coshSQL
"create table coshTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO coshTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'abcd',
X'abcd')",
@@ -137,8 +127,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO coshTable(Time,device_id,s4) values(3, 'd1', 3.5)",
"INSERT INTO coshTable(Time,device_id,s5) values(2, 'd1', 2.5)",
"INSERT INTO coshTable(Time,device_id,s5) values(3, 'd1', 3.5)",
- "INSERT INTO coshTable(Time,device_id,s8) values(2, 'd1', 2)",
- "INSERT INTO coshTable(Time,device_id,s8) values(3, 'd1', 3)",
// degreesSQL
"create table degreesTable(device_id STRING ID, s1 TEXT MEASUREMENT,
s2 INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO
degreesTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10) values(1, 'd1',
'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'abcd', X'abcd')",
@@ -150,8 +138,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO degreesTable(Time,device_id,s4) values(3, 'd1', 3.5)",
"INSERT INTO degreesTable(Time,device_id,s5) values(2, 'd1', 2.5)",
"INSERT INTO degreesTable(Time,device_id,s5) values(3, 'd1', 3.5)",
- "INSERT INTO degreesTable(Time,device_id,s8) values(2, 'd1', 2)",
- "INSERT INTO degreesTable(Time,device_id,s8) values(3, 'd1', 3)",
// endsWithSQL
"create table endsWithTable(device_id STRING ID, s1 TEXT MEASUREMENT,
s2 INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO
endsWithTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10) values(1, 'd1',
'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'ab', X'abcd')",
@@ -170,8 +156,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO expTable(Time,device_id,s4) values(3, 'd1', 3.5)",
"INSERT INTO expTable(Time,device_id,s5) values(2, 'd1', 2.5)",
"INSERT INTO expTable(Time,device_id,s5) values(3, 'd1', 3.5)",
- "INSERT INTO expTable(Time,device_id,s8) values(2, 'd1', 2)",
- "INSERT INTO expTable(Time,device_id,s8) values(3, 'd1', 3)",
// floorSQL
"create table floorTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO floorTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'abcd',
X'abcd')",
@@ -183,8 +167,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO floorTable(Time,device_id,s4) values(3, 'd1', -2.5)",
"INSERT INTO floorTable(Time,device_id,s5) values(2, 'd1', 2.5)",
"INSERT INTO floorTable(Time,device_id,s5) values(3, 'd1', -2.5)",
- "INSERT INTO floorTable(Time,device_id,s8) values(2, 'd1', 2)",
- "INSERT INTO floorTable(Time,device_id,s8) values(3, 'd1', 3)",
// lengthSQL
"create table lengthTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO
lengthTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10) values(1, 'd1',
'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'abcd', X'abcd')",
@@ -203,8 +185,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO lnTable(Time,device_id,s4) values(3, 'd1', -3.5)",
"INSERT INTO lnTable(Time,device_id,s5) values(2, 'd1', 0.0)",
"INSERT INTO lnTable(Time,device_id,s5) values(3, 'd1', -3.5)",
- "INSERT INTO lnTable(Time,device_id,s8) values(2, 'd1', 0)",
- "INSERT INTO lnTable(Time,device_id,s8) values(3, 'd1', 3)",
// log10SQL
"create table log10Table(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO log10Table(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'abcd',
X'abcd')",
@@ -216,8 +196,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO log10Table(Time,device_id,s4) values(3, 'd1', -3.5)",
"INSERT INTO log10Table(Time,device_id,s5) values(2, 'd1', 0.0)",
"INSERT INTO log10Table(Time,device_id,s5) values(3, 'd1', -3.5)",
- "INSERT INTO log10Table(Time,device_id,s8) values(2, 'd1', 0)",
- "INSERT INTO log10Table(Time,device_id,s8) values(3, 'd1', 3)",
// lowerSQL
"create table lowerTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO lowerTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'ABCD', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'ABCD',
X'abcd')",
@@ -236,8 +214,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO radiansTable(Time,device_id,s4) values(3, 'd1', 3.5)",
"INSERT INTO radiansTable(Time,device_id,s5) values(2, 'd1', 2.5)",
"INSERT INTO radiansTable(Time,device_id,s5) values(3, 'd1', 3.5)",
- "INSERT INTO radiansTable(Time,device_id,s8) values(2, 'd1', 2)",
- "INSERT INTO radiansTable(Time,device_id,s8) values(3, 'd1', 3)",
// regexpLikeSQL
"create table regexpLikeTable(device_id STRING ID, s1 TEXT
MEASUREMENT, s2 INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT,
s5 DOUBLE MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8
TIMESTAMP MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO
regexpLikeTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10) values(1, 'd1',
'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'ab', X'abcd')",
@@ -256,8 +232,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO signTable(Time,device_id,s4) values(3, 'd1', -1.0)",
"INSERT INTO signTable(Time,device_id,s5) values(2, 'd1', 0.0)",
"INSERT INTO signTable(Time,device_id,s5) values(3, 'd1', -1.0)",
- "INSERT INTO signTable(Time,device_id,s8) values(2, 'd1', 0)",
- "INSERT INTO signTable(Time,device_id,s8) values(3, 'd1', 1)",
// sinSQL
"create table sinTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO sinTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'abcd',
X'abcd')",
@@ -269,8 +243,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO sinTable(Time,device_id,s4) values(3, 'd1', 3.5)",
"INSERT INTO sinTable(Time,device_id,s5) values(2, 'd1', 2.5)",
"INSERT INTO sinTable(Time,device_id,s5) values(3, 'd1', 3.5)",
- "INSERT INTO sinTable(Time,device_id,s8) values(2, 'd1', 2)",
- "INSERT INTO sinTable(Time,device_id,s8) values(3, 'd1', 3)",
// sinhSQL
"create table sinhTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO sinhTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'abcd',
X'abcd')",
@@ -282,8 +254,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO sinhTable(Time,device_id,s4) values(3, 'd1', 3.5)",
"INSERT INTO sinhTable(Time,device_id,s5) values(2, 'd1', 2.5)",
"INSERT INTO sinhTable(Time,device_id,s5) values(3, 'd1', 3.5)",
- "INSERT INTO sinhTable(Time,device_id,s8) values(2, 'd1', 2)",
- "INSERT INTO sinhTable(Time,device_id,s8) values(3, 'd1', 3)",
// sqrtSQL
"create table sqrtTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO sqrtTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'abcd',
X'abcd')",
@@ -295,8 +265,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO sqrtTable(Time,device_id,s4) values(3, 'd1', -1.5)",
"INSERT INTO sqrtTable(Time,device_id,s5) values(2, 'd1', 0.0)",
"INSERT INTO sqrtTable(Time,device_id,s5) values(3, 'd1', -1.5)",
- "INSERT INTO sqrtTable(Time,device_id,s8) values(2, 'd1', 0)",
- "INSERT INTO sqrtTable(Time,device_id,s8) values(3, 'd1', 3)",
// startsWithSQL
"create table startsWithTable(device_id STRING ID, s1 TEXT
MEASUREMENT, s2 INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT,
s5 DOUBLE MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8
TIMESTAMP MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO
startsWithTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10) values(1, 'd1',
'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'ab', X'abcd')",
@@ -329,8 +297,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO tanTable(Time,device_id,s4) values(3, 'd1', 3.5)",
"INSERT INTO tanTable(Time,device_id,s5) values(2, 'd1',
1.57079632675)",
"INSERT INTO tanTable(Time,device_id,s5) values(3, 'd1', 3.5)",
- "INSERT INTO tanTable(Time,device_id,s8) values(2, 'd1', 2)",
- "INSERT INTO tanTable(Time,device_id,s8) values(3, 'd1', 3)",
// tanhSQL
"create table tanhTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO tanhTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'abcd',
X'abcd')",
@@ -342,8 +308,6 @@ public class IoTDBScalarFunctionTableIT {
"INSERT INTO tanhTable(Time,device_id,s4) values(3, 'd1', 3.5)",
"INSERT INTO tanhTable(Time,device_id,s5) values(2, 'd1', 2.5)",
"INSERT INTO tanhTable(Time,device_id,s5) values(3, 'd1', 3.5)",
- "INSERT INTO tanhTable(Time,device_id,s8) values(2, 'd1', 2)",
- "INSERT INTO tanhTable(Time,device_id,s8) values(3, 'd1', 3)",
// trimSQL
"create table trimTable(device_id STRING ID, s1 TEXT MEASUREMENT, s2
INT32 MEASUREMENT, s3 INT64 MEASUREMENT, s4 FLOAT MEASUREMENT, s5 DOUBLE
MEASUREMENT, s6 BOOLEAN MEASUREMENT, s7 DATE MEASUREMENT, s8 TIMESTAMP
MEASUREMENT, s9 STRING MEASUREMENT, s10 BLOB MEASUREMENT)",
"INSERT INTO trimTable(Time,device_id,s1,s2,s3,s4,s5,s6,s7,s8,s9,s10)
values(1, 'd1', 'abcd', 1, 1, 1, 1, true, '2021-10-01', 1633046400000, 'ab',
X'abcd')",
@@ -388,17 +352,15 @@ public class IoTDBScalarFunctionTableIT {
public void absTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,1,1,1,1.0,1.0,1.0,1.0,2021-10-01T00:00:00.000Z,2021-10-01T00:00:00.000Z,",
-
"1970-01-01T00:00:00.002Z,-1,1,-1,1,-1.5,1.5,-1.5,1.5,1970-01-01T00:00:00.001Z,1970-01-01T00:00:00.001Z,",
-
"1970-01-01T00:00:00.003Z,-2,2,-2,2,-2.5,2.5,-2.5,2.5,1970-01-01T00:00:00.002Z,1970-01-01T00:00:00.002Z,",
+ "1970-01-01T00:00:00.001Z,1,1,1,1,1.0,1.0,1.0,1.0,",
+ "1970-01-01T00:00:00.002Z,-1,1,-1,1,-1.5,1.5,-1.5,1.5,",
+ "1970-01-01T00:00:00.003Z,-2,2,-2,2,-2.5,2.5,-2.5,2.5,",
};
tableResultSetEqualTest(
- "select time,s2,abs(s2),s3,abs(s3),s4,abs(s4),s5,abs(s5),s8,abs(s8)
from absTable",
+ "select time,s2,abs(s2),s3,abs(s3),s4,abs(s4),s5,abs(s5) from
absTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -453,16 +415,14 @@ public class IoTDBScalarFunctionTableIT {
public void acosTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP And range of
input value is [-1, 1]
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,0.0,1,0.0,1.0,0.0,1.0,0.0,1970-01-01T00:00:00.001Z,0.0,",
-
"1970-01-01T00:00:00.002Z,2,NaN,2,NaN,0.5,1.0471975511965979,0.5,1.0471975511965979,1970-01-01T00:00:00.002Z,NaN,",
+ "1970-01-01T00:00:00.001Z,1,0.0,1,0.0,1.0,0.0,1.0,0.0,",
+
"1970-01-01T00:00:00.002Z,2,NaN,2,NaN,0.5,1.0471975511965979,0.5,1.0471975511965979,",
};
tableResultSetEqualTest(
- "select
time,s2,acos(s2),s3,acos(s3),s4,acos(s4),s5,acos(s5),s8,acos(s8) from
acosTable",
+ "select time,s2,acos(s2),s3,acos(s3),s4,acos(s4),s5,acos(s5) from
acosTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -517,16 +477,14 @@ public class IoTDBScalarFunctionTableIT {
public void asinTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP And range of
input value is [-1, 1]
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,1.5707963267948966,1,1.5707963267948966,1.0,1.5707963267948966,1.0,1.5707963267948966,1970-01-01T00:00:00.001Z,1.5707963267948966,",
-
"1970-01-01T00:00:00.002Z,2,NaN,2,NaN,0.5,0.5235987755982989,0.5,0.5235987755982989,1970-01-01T00:00:00.002Z,NaN,",
+
"1970-01-01T00:00:00.001Z,1,1.5707963267948966,1,1.5707963267948966,1.0,1.5707963267948966,1.0,1.5707963267948966,",
+
"1970-01-01T00:00:00.002Z,2,NaN,2,NaN,0.5,0.5235987755982989,0.5,0.5235987755982989,",
};
tableResultSetEqualTest(
- "select
time,s2,asin(s2),s3,asin(s3),s4,asin(s4),s5,asin(s5),s8,asin(s8) from
asinTable",
+ "select time,s2,asin(s2),s3,asin(s3),s4,asin(s4),s5,asin(s5) from
asinTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -581,17 +539,15 @@ public class IoTDBScalarFunctionTableIT {
public void atanTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,0.7853981633974483,1,0.7853981633974483,1.0,0.7853981633974483,1.0,0.7853981633974483,2021-10-01T00:00:00.000Z,1.5707963267942842,",
-
"1970-01-01T00:00:00.002Z,2,1.1071487177940904,2,1.1071487177940904,2.5,1.1902899496825317,2.5,1.1902899496825317,1970-01-01T00:00:00.002Z,1.1071487177940904,",
-
"1970-01-01T00:00:00.003Z,3,1.2490457723982544,3,1.2490457723982544,3.5,1.2924966677897853,3.5,1.2924966677897853,1970-01-01T00:00:00.003Z,1.2490457723982544,",
+
"1970-01-01T00:00:00.001Z,1,0.7853981633974483,1,0.7853981633974483,1.0,0.7853981633974483,1.0,0.7853981633974483,",
+
"1970-01-01T00:00:00.002Z,2,1.1071487177940904,2,1.1071487177940904,2.5,1.1902899496825317,2.5,1.1902899496825317,",
+
"1970-01-01T00:00:00.003Z,3,1.2490457723982544,3,1.2490457723982544,3.5,1.2924966677897853,3.5,1.2924966677897853,",
};
tableResultSetEqualTest(
- "select
time,s2,atan(s2),s3,atan(s3),s4,atan(s4),s5,atan(s5),s8,atan(s8) from
atanTable",
+ "select time,s2,atan(s2),s3,atan(s3),s4,atan(s4),s5,atan(s5) from
atanTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -646,17 +602,15 @@ public class IoTDBScalarFunctionTableIT {
public void ceilTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,1.0,1,1.0,1.0,1.0,1.0,1.0,2021-10-01T00:00:00.000Z,1.6330464E12,",
-
"1970-01-01T00:00:00.002Z,2,2.0,2,2.0,2.5,3.0,2.5,3.0,1970-01-01T00:00:00.002Z,2.0,",
-
"1970-01-01T00:00:00.003Z,-2,-2.0,-2,-2.0,-2.5,-2.0,-2.5,-2.0,1970-01-01T00:00:00.003Z,3.0,",
+ "1970-01-01T00:00:00.001Z,1,1.0,1,1.0,1.0,1.0,1.0,1.0,",
+ "1970-01-01T00:00:00.002Z,2,2.0,2,2.0,2.5,3.0,2.5,3.0,",
+ "1970-01-01T00:00:00.003Z,-2,-2.0,-2,-2.0,-2.5,-2.0,-2.5,-2.0,",
};
tableResultSetEqualTest(
- "select
time,s2,ceil(s2),s3,ceil(s3),s4,ceil(s4),s5,ceil(s5),s8,ceil(s8) from
ceilTable",
+ "select time,s2,ceil(s2),s3,ceil(s3),s4,ceil(s4),s5,ceil(s5) from
ceilTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -840,17 +794,15 @@ public class IoTDBScalarFunctionTableIT {
public void cosTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,0.5403023058681398,1,0.5403023058681398,1.0,0.5403023058681398,1.0,0.5403023058681398,2021-10-01T00:00:00.000Z,-0.8897114604104552,",
-
"1970-01-01T00:00:00.002Z,2,-0.4161468365471424,2,-0.4161468365471424,2.5,-0.8011436155469337,2.5,-0.8011436155469337,1970-01-01T00:00:00.002Z,-0.4161468365471424,",
-
"1970-01-01T00:00:00.003Z,3,-0.9899924966004454,3,-0.9899924966004454,3.5,-0.9364566872907963,3.5,-0.9364566872907963,1970-01-01T00:00:00.003Z,-0.9899924966004454,",
+
"1970-01-01T00:00:00.001Z,1,0.5403023058681398,1,0.5403023058681398,1.0,0.5403023058681398,1.0,0.5403023058681398,",
+
"1970-01-01T00:00:00.002Z,2,-0.4161468365471424,2,-0.4161468365471424,2.5,-0.8011436155469337,2.5,-0.8011436155469337,",
+
"1970-01-01T00:00:00.003Z,3,-0.9899924966004454,3,-0.9899924966004454,3.5,-0.9364566872907963,3.5,-0.9364566872907963,",
};
tableResultSetEqualTest(
- "select time,s2,cos(s2),s3,cos(s3),s4,cos(s4),s5,cos(s5),s8,cos(s8)
from cosTable",
+ "select time,s2,cos(s2),s3,cos(s3),s4,cos(s4),s5,cos(s5) from
cosTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -905,17 +857,15 @@ public class IoTDBScalarFunctionTableIT {
public void coshTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,1.543080634815244,1,1.543080634815244,1.0,1.543080634815244,1.0,1.543080634815244,2021-10-01T00:00:00.000Z,Infinity,",
-
"1970-01-01T00:00:00.002Z,2,3.7621956910836314,2,3.7621956910836314,2.5,6.132289479663686,2.5,6.132289479663686,1970-01-01T00:00:00.002Z,3.7621956910836314,",
-
"1970-01-01T00:00:00.003Z,3,10.067661995777765,3,10.067661995777765,3.5,16.572824671057315,3.5,16.572824671057315,1970-01-01T00:00:00.003Z,10.067661995777765,",
+
"1970-01-01T00:00:00.001Z,1,1.543080634815244,1,1.543080634815244,1.0,1.543080634815244,1.0,1.543080634815244,",
+
"1970-01-01T00:00:00.002Z,2,3.7621956910836314,2,3.7621956910836314,2.5,6.132289479663686,2.5,6.132289479663686,",
+
"1970-01-01T00:00:00.003Z,3,10.067661995777765,3,10.067661995777765,3.5,16.572824671057315,3.5,16.572824671057315,",
};
tableResultSetEqualTest(
- "select
time,s2,cosh(s2),s3,cosh(s3),s4,cosh(s4),s5,cosh(s5),s8,cosh(s8) from
coshTable",
+ "select time,s2,cosh(s2),s3,cosh(s3),s4,cosh(s4),s5,cosh(s5) from
coshTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -970,17 +920,15 @@ public class IoTDBScalarFunctionTableIT {
public void degreesTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,57.29577951308232,1,57.29577951308232,1.0,57.29577951308232,1.0,57.29577951308232,2021-10-01T00:00:00.000Z,9.356666646903284E13,",
-
"1970-01-01T00:00:00.002Z,2,114.59155902616465,2,114.59155902616465,2.5,143.2394487827058,2.5,143.2394487827058,1970-01-01T00:00:00.002Z,114.59155902616465,",
-
"1970-01-01T00:00:00.003Z,3,171.88733853924697,3,171.88733853924697,3.5,200.53522829578813,3.5,200.53522829578813,1970-01-01T00:00:00.003Z,171.88733853924697,",
+
"1970-01-01T00:00:00.001Z,1,57.29577951308232,1,57.29577951308232,1.0,57.29577951308232,1.0,57.29577951308232,",
+
"1970-01-01T00:00:00.002Z,2,114.59155902616465,2,114.59155902616465,2.5,143.2394487827058,2.5,143.2394487827058,",
+
"1970-01-01T00:00:00.003Z,3,171.88733853924697,3,171.88733853924697,3.5,200.53522829578813,3.5,200.53522829578813,",
};
tableResultSetEqualTest(
- "select
time,s2,degrees(s2),s3,degrees(s3),s4,degrees(s4),s5,degrees(s5),s8,degrees(s8)
from degreesTable",
+ "select
time,s2,degrees(s2),s3,degrees(s3),s4,degrees(s4),s5,degrees(s5) from
degreesTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -1139,17 +1087,15 @@ public class IoTDBScalarFunctionTableIT {
public void expTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,2.718281828459045,1,2.718281828459045,1.0,2.718281828459045,1.0,2.718281828459045,2021-10-01T00:00:00.000Z,Infinity,",
-
"1970-01-01T00:00:00.002Z,2,7.38905609893065,2,7.38905609893065,2.5,12.182493960703473,2.5,12.182493960703473,1970-01-01T00:00:00.002Z,7.38905609893065,",
-
"1970-01-01T00:00:00.003Z,3,20.085536923187668,3,20.085536923187668,3.5,33.11545195869231,3.5,33.11545195869231,1970-01-01T00:00:00.003Z,20.085536923187668,",
+
"1970-01-01T00:00:00.001Z,1,2.718281828459045,1,2.718281828459045,1.0,2.718281828459045,1.0,2.718281828459045,",
+
"1970-01-01T00:00:00.002Z,2,7.38905609893065,2,7.38905609893065,2.5,12.182493960703473,2.5,12.182493960703473,",
+
"1970-01-01T00:00:00.003Z,3,20.085536923187668,3,20.085536923187668,3.5,33.11545195869231,3.5,33.11545195869231,",
};
tableResultSetEqualTest(
- "select time,s2,exp(s2),s3,exp(s3),s4,exp(s4),s5,exp(s5),s8,exp(s8)
from expTable",
+ "select time,s2,exp(s2),s3,exp(s3),s4,exp(s4),s5,exp(s5) from
expTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -1204,17 +1150,15 @@ public class IoTDBScalarFunctionTableIT {
public void floorTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,1.0,1,1.0,1.0,1.0,1.0,1.0,2021-10-01T00:00:00.000Z,1.6330464E12,",
-
"1970-01-01T00:00:00.002Z,2,2.0,2,2.0,2.5,2.0,2.5,2.0,1970-01-01T00:00:00.002Z,2.0,",
-
"1970-01-01T00:00:00.003Z,-2,-2.0,-2,-2.0,-2.5,-3.0,-2.5,-3.0,1970-01-01T00:00:00.003Z,3.0,",
+ "1970-01-01T00:00:00.001Z,1,1.0,1,1.0,1.0,1.0,1.0,1.0,",
+ "1970-01-01T00:00:00.002Z,2,2.0,2,2.0,2.5,2.0,2.5,2.0,",
+ "1970-01-01T00:00:00.003Z,-2,-2.0,-2,-2.0,-2.5,-3.0,-2.5,-3.0,",
};
tableResultSetEqualTest(
- "select
time,s2,floor(s2),s3,floor(s3),s4,floor(s4),s5,floor(s5),s8,floor(s8) from
floorTable",
+ "select time,s2,floor(s2),s3,floor(s3),s4,floor(s4),s5,floor(s5) from
floorTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -1360,17 +1304,15 @@ public class IoTDBScalarFunctionTableIT {
public void lnTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,0.0,1,0.0,1.0,0.0,1.0,0.0,2021-10-01T00:00:00.000Z,28.12146834347524,",
-
"1970-01-01T00:00:00.002Z,0,-Infinity,0,-Infinity,0.0,-Infinity,0.0,-Infinity,1970-01-01T00:00:00.000Z,-Infinity,",
-
"1970-01-01T00:00:00.003Z,-3,NaN,-3,NaN,-3.5,NaN,-3.5,NaN,1970-01-01T00:00:00.003Z,1.0986122886681098,",
+ "1970-01-01T00:00:00.001Z,1,0.0,1,0.0,1.0,0.0,1.0,0.0,",
+
"1970-01-01T00:00:00.002Z,0,-Infinity,0,-Infinity,0.0,-Infinity,0.0,-Infinity,",
+ "1970-01-01T00:00:00.003Z,-3,NaN,-3,NaN,-3.5,NaN,-3.5,NaN,",
};
tableResultSetEqualTest(
- "select time,s2,ln(s2),s3,ln(s3),s4,ln(s4),s5,ln(s5),s8,ln(s8) from
lnTable",
+ "select time,s2,ln(s2),s3,ln(s3),s4,ln(s4),s5,ln(s5) from lnTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -1425,17 +1367,15 @@ public class IoTDBScalarFunctionTableIT {
public void log10TestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,0.0,1,0.0,1.0,0.0,1.0,0.0,2021-10-01T00:00:00.000Z,12.212998524588278,",
-
"1970-01-01T00:00:00.002Z,0,-Infinity,0,-Infinity,0.0,-Infinity,0.0,-Infinity,1970-01-01T00:00:00.000Z,-Infinity,",
-
"1970-01-01T00:00:00.003Z,-3,NaN,-3,NaN,-3.5,NaN,-3.5,NaN,1970-01-01T00:00:00.003Z,0.47712125471966244,",
+ "1970-01-01T00:00:00.001Z,1,0.0,1,0.0,1.0,0.0,1.0,0.0,",
+
"1970-01-01T00:00:00.002Z,0,-Infinity,0,-Infinity,0.0,-Infinity,0.0,-Infinity,",
+ "1970-01-01T00:00:00.003Z,-3,NaN,-3,NaN,-3.5,NaN,-3.5,NaN,",
};
tableResultSetEqualTest(
- "select
time,s2,log10(s2),s3,log10(s3),s4,log10(s4),s5,log10(s5),s8,log10(s8) from
log10Table",
+ "select time,s2,log10(s2),s3,log10(s3),s4,log10(s4),s5,log10(s5) from
log10Table",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -1572,21 +1512,19 @@ public class IoTDBScalarFunctionTableIT {
@Test
public void radiansTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
- String[] expectedHeader = new String[] {"time", "_col1", "_col2", "_col3",
"_col4", "_col5"};
+ String[] expectedHeader = new String[] {"time", "_col1", "_col2", "_col3",
"_col4"};
int[] expectedBodyInt = new int[] {1, 2, 3};
long[] expectedBodyLong = new long[] {1, 2, 3};
float[] expectedBodyFloat = new float[] {1, 2.5f, 3.5f};
double[] expectedBodyDouble = new double[] {1, 2.5, 3.5};
- long[] expectedBodyTimestamp = new long[] {1633046400000L, 2, 3};
testRadiansDoubleResult(
- "select
time,radians(s2),radians(s3),radians(s4),radians(s5),radians(s8) from
radiansTable",
+ "select time,radians(s2),radians(s3),radians(s4),radians(s5) from
radiansTable",
expectedHeader,
DATABASE_NAME,
expectedBodyInt,
expectedBodyLong,
expectedBodyFloat,
- expectedBodyDouble,
- expectedBodyTimestamp);
+ expectedBodyDouble);
}
private void testRadiansDoubleResult(
@@ -1596,8 +1534,7 @@ public class IoTDBScalarFunctionTableIT {
int[] expectedBodyInt,
long[] expectedBodyLong,
float[] expectedBodyFloat,
- double[] expectedBodyDouble,
- long[] expectedBodyTimestamp) {
+ double[] expectedBodyDouble) {
try (Connection connection =
EnvFactory.getEnv()
.getConnection(
@@ -1632,10 +1569,6 @@ public class IoTDBScalarFunctionTableIT {
Math.toRadians(expectedBodyDouble[cnt]),
Double.parseDouble(resultSet.getString(5)),
0.00001);
- assertEquals(
- Math.toRadians(expectedBodyTimestamp[cnt]),
- Double.parseDouble(resultSet.getString(6)),
- 0.00001);
for (int i = 1; i < expectedHeader.length; i++) {
System.out.println(resultSet.getString(i));
@@ -1804,17 +1737,15 @@ public class IoTDBScalarFunctionTableIT {
public void signTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,1,1,1,1.0,1.0,1.0,1.0,2021-10-01T00:00:00.000Z,1,",
-
"1970-01-01T00:00:00.002Z,0,0,0,0,0.0,0.0,0.0,0.0,1970-01-01T00:00:00.000Z,0,",
-
"1970-01-01T00:00:00.003Z,-1,-1,-1,-1,-1.0,-1.0,-1.0,-1.0,1970-01-01T00:00:00.001Z,1,",
+ "1970-01-01T00:00:00.001Z,1,1,1,1,1.0,1.0,1.0,1.0,",
+ "1970-01-01T00:00:00.002Z,0,0,0,0,0.0,0.0,0.0,0.0,",
+ "1970-01-01T00:00:00.003Z,-1,-1,-1,-1,-1.0,-1.0,-1.0,-1.0,",
};
tableResultSetEqualTest(
- "select
time,s2,sign(s2),s3,sign(s3),s4,sign(s4),s5,sign(s5),s8,sign(s8) from
signTable",
+ "select time,s2,sign(s2),s3,sign(s3),s4,sign(s4),s5,sign(s5) from
signTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -1869,17 +1800,15 @@ public class IoTDBScalarFunctionTableIT {
public void sinTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,0.8414709848078965,1,0.8414709848078965,1.0,0.8414709848078965,1.0,0.8414709848078965,2021-10-01T00:00:00.000Z,0.4565232931782287,",
-
"1970-01-01T00:00:00.002Z,2,0.9092974268256817,2,0.9092974268256817,2.5,0.5984721441039564,2.5,0.5984721441039564,1970-01-01T00:00:00.002Z,0.9092974268256817,",
-
"1970-01-01T00:00:00.003Z,3,0.1411200080598672,3,0.1411200080598672,3.5,-0.35078322768961984,3.5,-0.35078322768961984,1970-01-01T00:00:00.003Z,0.1411200080598672,",
+
"1970-01-01T00:00:00.001Z,1,0.8414709848078965,1,0.8414709848078965,1.0,0.8414709848078965,1.0,0.8414709848078965,",
+
"1970-01-01T00:00:00.002Z,2,0.9092974268256817,2,0.9092974268256817,2.5,0.5984721441039564,2.5,0.5984721441039564,",
+
"1970-01-01T00:00:00.003Z,3,0.1411200080598672,3,0.1411200080598672,3.5,-0.35078322768961984,3.5,-0.35078322768961984,",
};
tableResultSetEqualTest(
- "select time,s2,sin(s2),s3,sin(s3),s4,sin(s4),s5,sin(s5),s8,sin(s8)
from sinTable",
+ "select time,s2,sin(s2),s3,sin(s3),s4,sin(s4),s5,sin(s5) from
sinTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -1934,17 +1863,15 @@ public class IoTDBScalarFunctionTableIT {
public void sinhTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,1.1752011936438014,1,1.1752011936438014,1.0,1.1752011936438014,1.0,1.1752011936438014,2021-10-01T00:00:00.000Z,Infinity,",
-
"1970-01-01T00:00:00.002Z,2,3.626860407847019,2,3.626860407847019,2.5,6.0502044810397875,2.5,6.0502044810397875,1970-01-01T00:00:00.002Z,3.626860407847019,",
-
"1970-01-01T00:00:00.003Z,3,10.017874927409903,3,10.017874927409903,3.5,16.542627287634996,3.5,16.542627287634996,1970-01-01T00:00:00.003Z,10.017874927409903,",
+
"1970-01-01T00:00:00.001Z,1,1.1752011936438014,1,1.1752011936438014,1.0,1.1752011936438014,1.0,1.1752011936438014,",
+
"1970-01-01T00:00:00.002Z,2,3.626860407847019,2,3.626860407847019,2.5,6.0502044810397875,2.5,6.0502044810397875,",
+
"1970-01-01T00:00:00.003Z,3,10.017874927409903,3,10.017874927409903,3.5,16.542627287634996,3.5,16.542627287634996,",
};
tableResultSetEqualTest(
- "select
time,s2,sinh(s2),s3,sinh(s3),s4,sinh(s4),s5,sinh(s5),s8,sinh(s8) from
sinhTable",
+ "select time,s2,sinh(s2),s3,sinh(s3),s4,sinh(s4),s5,sinh(s5) from
sinhTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -1999,17 +1926,15 @@ public class IoTDBScalarFunctionTableIT {
public void sqrtTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,1.0,1,1.0,1.0,1.0,1.0,1.0,2021-10-01T00:00:00.000Z,1277907.0388725465,",
-
"1970-01-01T00:00:00.002Z,0,0.0,0,0.0,0.0,0.0,0.0,0.0,1970-01-01T00:00:00.000Z,0.0,",
-
"1970-01-01T00:00:00.003Z,-1,NaN,-1,NaN,-1.5,NaN,-1.5,NaN,1970-01-01T00:00:00.003Z,1.7320508075688772,",
+ "1970-01-01T00:00:00.001Z,1,1.0,1,1.0,1.0,1.0,1.0,1.0,",
+ "1970-01-01T00:00:00.002Z,0,0.0,0,0.0,0.0,0.0,0.0,0.0,",
+ "1970-01-01T00:00:00.003Z,-1,NaN,-1,NaN,-1.5,NaN,-1.5,NaN,",
};
tableResultSetEqualTest(
- "select
time,s2,sqrt(s2),s3,sqrt(s3),s4,sqrt(s4),s5,sqrt(s5),s8,sqrt(s8) from
sqrtTable",
+ "select time,s2,sqrt(s2),s3,sqrt(s3),s4,sqrt(s4),s5,sqrt(s5) from
sqrtTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -2376,17 +2301,15 @@ public class IoTDBScalarFunctionTableIT {
public void tanTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,1.5574077246549023,1,1.5574077246549023,1.0,1.5574077246549023,1.0,1.5574077246549023,2021-10-01T00:00:00.000Z,-0.513113872858981,",
-
"1970-01-01T00:00:00.002Z,2,-2.185039863261519,2,-2.185039863261519,1.5707964,-2.287733242885646E7,1.57079632675,2.227340543395435E10,1970-01-01T00:00:00.002Z,-2.185039863261519,",
-
"1970-01-01T00:00:00.003Z,3,-0.1425465430742778,3,-0.1425465430742778,3.5,0.3745856401585947,3.5,0.3745856401585947,1970-01-01T00:00:00.003Z,-0.1425465430742778,",
+
"1970-01-01T00:00:00.001Z,1,1.5574077246549023,1,1.5574077246549023,1.0,1.5574077246549023,1.0,1.5574077246549023,",
+
"1970-01-01T00:00:00.002Z,2,-2.185039863261519,2,-2.185039863261519,1.5707964,-2.287733242885646E7,1.57079632675,2.227340543395435E10,",
+
"1970-01-01T00:00:00.003Z,3,-0.1425465430742778,3,-0.1425465430742778,3.5,0.3745856401585947,3.5,0.3745856401585947,",
};
tableResultSetEqualTest(
- "select time,s2,tan(s2),s3,tan(s3),s4,tan(s4),s5,tan(s5),s8,tan(s8)
from tanTable",
+ "select time,s2,tan(s2),s3,tan(s3),s4,tan(s4),s5,tan(s5) from
tanTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
@@ -2441,17 +2364,15 @@ public class IoTDBScalarFunctionTableIT {
public void tanhTestNormal() {
// case 1: support INT32, INT64, FLOAT, DOUBLE, TIMESTAMP
String[] expectedHeader =
- new String[] {
- "time", "s2", "_col2", "s3", "_col4", "s4", "_col6", "s5", "_col8",
"s8", "_col10"
- };
+ new String[] {"time", "s2", "_col2", "s3", "_col4", "s4", "_col6",
"s5", "_col8"};
String[] expectedAns =
new String[] {
-
"1970-01-01T00:00:00.001Z,1,0.7615941559557649,1,0.7615941559557649,1.0,0.7615941559557649,1.0,0.7615941559557649,2021-10-01T00:00:00.000Z,1.0,",
-
"1970-01-01T00:00:00.002Z,2,0.9640275800758169,2,0.9640275800758169,2.5,0.9866142981514303,2.5,0.9866142981514303,1970-01-01T00:00:00.002Z,0.9640275800758169,",
-
"1970-01-01T00:00:00.003Z,3,0.9950547536867305,3,0.9950547536867305,3.5,0.9981778976111987,3.5,0.9981778976111987,1970-01-01T00:00:00.003Z,0.9950547536867305,",
+
"1970-01-01T00:00:00.001Z,1,0.7615941559557649,1,0.7615941559557649,1.0,0.7615941559557649,1.0,0.7615941559557649,",
+
"1970-01-01T00:00:00.002Z,2,0.9640275800758169,2,0.9640275800758169,2.5,0.9866142981514303,2.5,0.9866142981514303,",
+
"1970-01-01T00:00:00.003Z,3,0.9950547536867305,3,0.9950547536867305,3.5,0.9981778976111987,3.5,0.9981778976111987,",
};
tableResultSetEqualTest(
- "select
time,s2,tanh(s2),s3,tanh(s3),s4,tanh(s4),s5,tanh(s5),s8,tanh(s8) from
tanhTable",
+ "select time,s2,tanh(s2),s3,tanh(s3),s4,tanh(s4),s5,tanh(s5) from
tanhTable",
expectedHeader,
expectedAns,
DATABASE_NAME);
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/relational/ColumnTransformerBuilder.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/relational/ColumnTransformerBuilder.java
index 4f73f5fd4d6..883efecec1c 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/relational/ColumnTransformerBuilder.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/relational/ColumnTransformerBuilder.java
@@ -156,7 +156,6 @@ import java.util.stream.Collectors;
import static com.google.common.base.Preconditions.checkArgument;
import static
org.apache.iotdb.db.queryengine.plan.relational.analyzer.predicate.PredicatePushIntoMetadataChecker.isStringLiteral;
-import static
org.apache.iotdb.db.queryengine.plan.relational.metadata.TableMetadataImpl.isTimestampType;
import static
org.apache.iotdb.db.queryengine.plan.relational.type.InternalTypeManager.getTSDataType;
import static
org.apache.iotdb.db.queryengine.plan.relational.type.TypeSignatureTranslator.toTypeSignature;
import static org.apache.tsfile.read.common.type.BlobType.BLOB;
@@ -666,53 +665,50 @@ public class ColumnTransformerBuilder
} else if
(TableBuiltinScalarFunction.UPPER.getFunctionName().equalsIgnoreCase(functionName))
{
ColumnTransformer first = this.process(children.get(0), context);
if (children.size() == 1) {
- return new UpperColumnTransformer(first.getType(), first);
+ return new UpperColumnTransformer(STRING, first);
}
} else if
(TableBuiltinScalarFunction.LOWER.getFunctionName().equalsIgnoreCase(functionName))
{
ColumnTransformer first = this.process(children.get(0), context);
if (children.size() == 1) {
- return new LowerColumnTransformer(first.getType(), first);
+ return new LowerColumnTransformer(STRING, first);
}
} else if
(TableBuiltinScalarFunction.TRIM.getFunctionName().equalsIgnoreCase(functionName))
{
ColumnTransformer first = this.process(children.get(0), context);
if (children.size() == 1) {
- return new TrimColumnTransformer(first.getType(), first, " ");
+ return new TrimColumnTransformer(STRING, first, " ");
} else {
// children.size() == 2
if (isStringLiteral(children.get(1))) {
return new TrimColumnTransformer(
- first.getType(), first, ((StringLiteral)
children.get(1)).getValue());
+ STRING, first, ((StringLiteral) children.get(1)).getValue());
} else {
- return new Trim2ColumnTransformer(
- first.getType(), first, this.process(children.get(1), context));
+ return new Trim2ColumnTransformer(STRING, first,
this.process(children.get(1), context));
}
}
} else if
(TableBuiltinScalarFunction.LTRIM.getFunctionName().equalsIgnoreCase(functionName))
{
ColumnTransformer first = this.process(children.get(0), context);
if (children.size() == 1) {
- return new LTrimColumnTransformer(first.getType(), first, " ");
+ return new LTrimColumnTransformer(STRING, first, " ");
} else {
// children.size() == 2
if (isStringLiteral(children.get(1))) {
return new LTrimColumnTransformer(
- first.getType(), first, ((StringLiteral)
children.get(1)).getValue());
+ STRING, first, ((StringLiteral) children.get(1)).getValue());
} else {
- return new LTrim2ColumnTransformer(
- first.getType(), first, this.process(children.get(1), context));
+ return new LTrim2ColumnTransformer(STRING, first,
this.process(children.get(1), context));
}
}
} else if
(TableBuiltinScalarFunction.RTRIM.getFunctionName().equalsIgnoreCase(functionName))
{
ColumnTransformer first = this.process(children.get(0), context);
if (children.size() == 1) {
- return new RTrimColumnTransformer(first.getType(), first, " ");
+ return new RTrimColumnTransformer(STRING, first, " ");
} else {
// children.size() == 2
if (isStringLiteral(children.get(1))) {
return new RTrimColumnTransformer(
- first.getType(), first, ((StringLiteral)
children.get(1)).getValue());
+ STRING, first, ((StringLiteral) children.get(1)).getValue());
} else {
- return new RTrim2ColumnTransformer(
- first.getType(), first, this.process(children.get(1), context));
+ return new RTrim2ColumnTransformer(STRING, first,
this.process(children.get(1), context));
}
}
} else if (TableBuiltinScalarFunction.REGEXP_LIKE
@@ -868,11 +864,7 @@ public class ColumnTransformerBuilder
} else if
(TableBuiltinScalarFunction.SIGN.getFunctionName().equalsIgnoreCase(functionName))
{
ColumnTransformer first = this.process(children.get(0), context);
if (children.size() == 1) {
- if (isTimestampType(first.getType())) {
- return new SignColumnTransformer(INT64, first);
- } else {
- return new SignColumnTransformer(first.getType(), first);
- }
+ return new SignColumnTransformer(first.getType(), first);
}
} else if
(TableBuiltinScalarFunction.CEIL.getFunctionName().equalsIgnoreCase(functionName))
{
ColumnTransformer first = this.process(children.get(0), context);
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/TableMetadataImpl.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/TableMetadataImpl.java
index ae155c94d5f..bfe07f693f4 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/TableMetadataImpl.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/TableMetadataImpl.java
@@ -208,7 +208,7 @@ public class TableMetadataImpl implements Metadata {
+ functionName.toLowerCase(Locale.ENGLISH)
+ " only accepts one argument and it must be text or string
data type.");
}
- return argumentTypes.get(0);
+ return STRING;
} else if
(TableBuiltinScalarFunction.LOWER.getFunctionName().equalsIgnoreCase(functionName))
{
if (!(argumentTypes.size() == 1 && isCharType(argumentTypes.get(0)))) {
throw new SemanticException(
@@ -216,7 +216,7 @@ public class TableMetadataImpl implements Metadata {
+ functionName.toLowerCase(Locale.ENGLISH)
+ " only accepts one argument and it must be text or string
data type.");
}
- return argumentTypes.get(0);
+ return STRING;
} else if
(TableBuiltinScalarFunction.TRIM.getFunctionName().equalsIgnoreCase(functionName))
{
if (!(argumentTypes.size() == 1 && isCharType(argumentTypes.get(0)))
&& !(argumentTypes.size() == 2 && isTwoCharType(argumentTypes))) {
@@ -225,7 +225,7 @@ public class TableMetadataImpl implements Metadata {
+ functionName.toLowerCase(Locale.ENGLISH)
+ " only accepts one or two arguments and they must be text or
string data type.");
}
- return argumentTypes.get(0);
+ return STRING;
} else if
(TableBuiltinScalarFunction.LTRIM.getFunctionName().equalsIgnoreCase(functionName))
{
if (!(argumentTypes.size() == 1 && isCharType(argumentTypes.get(0)))
&& !(argumentTypes.size() == 2 && isTwoCharType(argumentTypes))) {
@@ -234,7 +234,7 @@ public class TableMetadataImpl implements Metadata {
+ functionName.toLowerCase(Locale.ENGLISH)
+ " only accepts one or two arguments and they must be text or
string data type.");
}
- return argumentTypes.get(0);
+ return STRING;
} else if
(TableBuiltinScalarFunction.RTRIM.getFunctionName().equalsIgnoreCase(functionName))
{
if (!(argumentTypes.size() == 1 && isCharType(argumentTypes.get(0)))
&& !(argumentTypes.size() == 2 && isTwoCharType(argumentTypes))) {
@@ -243,7 +243,7 @@ public class TableMetadataImpl implements Metadata {
+ functionName.toLowerCase(Locale.ENGLISH)
+ " only accepts one or two arguments and they must be text or
string data type.");
}
- return argumentTypes.get(0);
+ return STRING;
} else if (TableBuiltinScalarFunction.REGEXP_LIKE
.getFunctionName()
.equalsIgnoreCase(functionName)) {
@@ -300,7 +300,7 @@ public class TableMetadataImpl implements Metadata {
}
return INT32;
} else if
(TableBuiltinScalarFunction.SIN.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -308,7 +308,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.COS.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -316,7 +316,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.TAN.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -324,7 +324,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.ASIN.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -332,7 +332,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.ACOS.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -340,7 +340,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.ATAN.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -348,7 +348,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.SINH.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -356,7 +356,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.COSH.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -364,7 +364,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.TANH.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -374,7 +374,7 @@ public class TableMetadataImpl implements Metadata {
} else if (TableBuiltinScalarFunction.DEGREES
.getFunctionName()
.equalsIgnoreCase(functionName)) {
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -384,7 +384,7 @@ public class TableMetadataImpl implements Metadata {
} else if (TableBuiltinScalarFunction.RADIANS
.getFunctionName()
.equalsIgnoreCase(functionName)) {
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -392,7 +392,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.ABS.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -400,19 +400,15 @@ public class TableMetadataImpl implements Metadata {
}
return argumentTypes.get(0);
} else if
(TableBuiltinScalarFunction.SIGN.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
+ " only accepts one argument and it must be TimeStamp,
Double, Float, Int32 or Int64 data type.");
}
- if (isTimestampType(argumentTypes.get(0))) {
- return INT64;
- } else {
- return argumentTypes.get(0);
- }
+ return argumentTypes.get(0);
} else if
(TableBuiltinScalarFunction.CEIL.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -420,7 +416,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.FLOOR.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -428,7 +424,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.EXP.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -436,7 +432,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.LN.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -444,7 +440,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.LOG10.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -452,7 +448,7 @@ public class TableMetadataImpl implements Metadata {
}
return DOUBLE;
} else if
(TableBuiltinScalarFunction.SQRT.getFunctionName().equalsIgnoreCase(functionName))
{
- if (!(argumentTypes.size() == 1 && isNumericType(argumentTypes.get(0))))
{
+ if (!(argumentTypes.size() == 1 &&
isSupportedMathNumericType(argumentTypes.get(0)))) {
throw new SemanticException(
"Scalar function "
+ functionName.toLowerCase(Locale.ENGLISH)
@@ -671,6 +667,10 @@ public class TableMetadataImpl implements Metadata {
return TEXT.equals(type) || StringType.STRING.equals(type);
}
+ public static boolean isSupportedMathNumericType(Type type) {
+ return DOUBLE.equals(type) || FLOAT.equals(type) || INT32.equals(type) ||
INT64.equals(type);
+ }
+
public static boolean isNumericType(Type type) {
return DOUBLE.equals(type)
|| FLOAT.equals(type)
@@ -679,10 +679,6 @@ public class TableMetadataImpl implements Metadata {
|| TimestampType.TIMESTAMP.equals(type);
}
- public static boolean isTimestampType(Type type) {
- return TimestampType.TIMESTAMP.equals(type);
- }
-
public static boolean isIntegerNumber(Type type) {
return INT32.equals(type) || INT64.equals(type);
}
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/AstBuilder.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/AstBuilder.java
index 909acf341ca..cf86eb12904 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/AstBuilder.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/parser/AstBuilder.java
@@ -144,6 +144,7 @@ import
org.apache.iotdb.db.queryengine.plan.statement.crud.InsertRowStatement;
import org.apache.iotdb.db.queryengine.plan.statement.crud.InsertRowsStatement;
import org.apache.iotdb.db.queryengine.plan.statement.sys.FlushStatement;
import
org.apache.iotdb.db.queryengine.plan.statement.sys.SetConfigurationStatement;
+import
org.apache.iotdb.db.queryengine.transformation.dag.column.unary.scalar.TableBuiltinScalarFunction;
import org.apache.iotdb.db.relational.grammar.sql.RelationalSqlBaseVisitor;
import org.apache.iotdb.db.relational.grammar.sql.RelationalSqlLexer;
import org.apache.iotdb.db.relational.grammar.sql.RelationalSqlParser;
@@ -1429,7 +1430,7 @@ public class AstBuilder extends
RelationalSqlBaseVisitor<Node> {
public Node visitConcatenation(RelationalSqlParser.ConcatenationContext ctx)
{
return new FunctionCall(
getLocation(ctx.CONCAT()),
- QualifiedName.of("concat"),
+ QualifiedName.of(TableBuiltinScalarFunction.CONCAT.getFunctionName()),
ImmutableList.of((Expression) visit(ctx.left), (Expression)
visit(ctx.right)));
}
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AcosColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AcosColumnTransformer.java
index 29b6e8ca239..c3bc4c28b7c 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AcosColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AcosColumnTransformer.java
@@ -42,8 +42,7 @@ public class AcosColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.acos(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.acos(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.acos((double) column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AsinColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AsinColumnTransformer.java
index d3f519e300a..691cda666f4 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AsinColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AsinColumnTransformer.java
@@ -42,8 +42,7 @@ public class AsinColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.asin(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.asin(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.asin((double) column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AtanColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AtanColumnTransformer.java
index 22c36017cff..5c45561ca73 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AtanColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AtanColumnTransformer.java
@@ -42,8 +42,7 @@ public class AtanColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.atan(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.atan(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.atan((double) column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CeilColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CeilColumnTransformer.java
index 86ba00a694c..c7332772127 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CeilColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CeilColumnTransformer.java
@@ -42,8 +42,7 @@ public class CeilColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.ceil(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(column.getInt(i));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(column.getLong(i));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CosColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CosColumnTransformer.java
index a9091ae3a18..ace4ecb70c9 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CosColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CosColumnTransformer.java
@@ -42,8 +42,7 @@ public class CosColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.cos(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.cos(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.cos((double) column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CoshColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CoshColumnTransformer.java
index 704c777b701..efe1104b89d 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CoshColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CoshColumnTransformer.java
@@ -42,8 +42,7 @@ public class CoshColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.cosh(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.cosh(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.cosh((double) column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/DegreesColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/DegreesColumnTransformer.java
index 54494383224..99736fcd4a2 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/DegreesColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/DegreesColumnTransformer.java
@@ -42,8 +42,7 @@ public class DegreesColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.toDegrees(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.toDegrees(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.toDegrees((double)
column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ExpColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ExpColumnTransformer.java
index 9e90f145cb2..fc6b01fbaec 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ExpColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ExpColumnTransformer.java
@@ -42,8 +42,7 @@ public class ExpColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.exp(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.exp(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.exp((double) column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/FloorColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/FloorColumnTransformer.java
index 0bb07d6edc0..74248670d7a 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/FloorColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/FloorColumnTransformer.java
@@ -42,8 +42,7 @@ public class FloorColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.floor(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(column.getInt(i));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(column.getLong(i));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LnColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LnColumnTransformer.java
index d334dbe1a07..9d231a053b0 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LnColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LnColumnTransformer.java
@@ -42,8 +42,7 @@ public class LnColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.log(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.log(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.log((double) column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Log10ColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Log10ColumnTransformer.java
index 6d5022171bd..69daf26bd84 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Log10ColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Log10ColumnTransformer.java
@@ -42,8 +42,7 @@ public class Log10ColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.log10(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.log10(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.log10((double) column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RadiansColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RadiansColumnTransformer.java
index 2bcdd619fbd..b93f2677bba 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RadiansColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RadiansColumnTransformer.java
@@ -42,8 +42,7 @@ public class RadiansColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.toRadians(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.toRadians(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.toRadians((double)
column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SignColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SignColumnTransformer.java
index 1bab00830b8..33edfc5d54a 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SignColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SignColumnTransformer.java
@@ -42,8 +42,7 @@ public class SignColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeFloat(Math.signum(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeInt((int) Math.signum(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeLong((long) Math.signum(column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SinColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SinColumnTransformer.java
index cbab6ed6182..57b2ac795cb 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SinColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SinColumnTransformer.java
@@ -42,8 +42,7 @@ public class SinColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.sin(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.sin(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.sin((double) column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SinhColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SinhColumnTransformer.java
index a8a5a8a9193..d1d64bed6d9 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SinhColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SinhColumnTransformer.java
@@ -42,8 +42,7 @@ public class SinhColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.sinh(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.sinh(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.sinh((double) column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SqrtColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SqrtColumnTransformer.java
index 2c1034a5ecd..a24900275bc 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SqrtColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SqrtColumnTransformer.java
@@ -42,8 +42,7 @@ public class SqrtColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.sqrt(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.sqrt(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.sqrt((double) column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TanColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TanColumnTransformer.java
index 2623658627e..211787e5e4e 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TanColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TanColumnTransformer.java
@@ -42,8 +42,7 @@ public class TanColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.tan(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.tan(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.tan((double) column.getLong(i)));
}
} else {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TanhColumnTransformer.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TanhColumnTransformer.java
index c6e845a01ae..39194899f2c 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TanhColumnTransformer.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TanhColumnTransformer.java
@@ -42,8 +42,7 @@ public class TanhColumnTransformer extends
UnaryColumnTransformer {
columnBuilder.writeDouble(Math.tanh(column.getFloat(i)));
} else if (TSDataType.INT32.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.tanh(column.getInt(i)));
- } else if (TSDataType.INT64.equals(column.getDataType())
- || TSDataType.TIMESTAMP.equals(column.getDataType())) {
+ } else if (TSDataType.INT64.equals(column.getDataType())) {
columnBuilder.writeDouble(Math.tanh((double) column.getLong(i)));
}
} else {
