Skip to content

Commit 1295c88

Browse files
committed
Add a test to unix_timestamp with microseconds
Signed-off-by: Yuanchun Shen <yuanchu@amazon.com>
1 parent 3ec719d commit 1295c88

1 file changed

Lines changed: 14 additions & 14 deletions

File tree

integ-test/src/test/java/org/opensearch/sql/calcite/standalone/CalcitePPLDateTimeBuiltinFunctionIT.java

Lines changed: 14 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -353,35 +353,35 @@ public void testToDays() {
353353
}
354354

355355
@Test
356-
public void testFromUnixTimeTwoArgument() {
356+
public void testFromUnixtime() {
357357
JSONObject actual =
358358
executeQuery(
359359
String.format(
360360
"source=%s "
361-
+ "| eval from_unix = FROM_UNIXTIME(1220249547, '%%T')"
362-
+ "| fields from_unix | head 1",
361+
+ "| eval from_unix_format = FROM_UNIXTIME(1220249547, '%%T')"
362+
+ "| eval from_unix = from_unixtime(1220249547)"
363+
+ "| fields from_unix_format | head 1",
363364
TEST_INDEX_DATE_FORMATS));
364-
verifySchema(actual, schema("from_unix", "string"));
365+
verifySchema(actual, schema("from_unix_format", "string"));
365366
verifyDataRows(actual, rows("06:12:27"));
366367
}
367368

368369
@Test
369-
public void testUnixTimeStampAndFromUnixTime() {
370+
public void testUnixTimestamp() {
370371
JSONObject actual =
371372
executeQuery(
372373
String.format(
373-
"source=%s "
374-
+ "| eval from_unix = from_unixtime(1220249547)"
375-
+ "| eval to_unix = unix_timestamp(from_unix)"
376-
+ "| eval unix_double = UNIX_TIMESTAMP(20771122143845)"
377-
+ "| fields from_unix, to_unix, unix_double | head 1",
374+
"source=%s | eval unix_timestamp = unix_timestamp(timestamp('2008-09-01"
375+
+ " 06:12:27'))| eval unix_long = UNIX_TIMESTAMP(20771122143845)| eval"
376+
+ " unix_ms = UNIX_TIMESTAMP(TIMESTAMP('2008-09-01 06:12:27.123456')) "
377+
+ "| fields unix_timestamp, unix_long, unix_ms | head 1",
378378
TEST_INDEX_DATE_FORMATS));
379379
verifySchema(
380380
actual,
381-
schema("from_unix", "timestamp"),
382-
schema("to_unix", "double"),
383-
schema("unix_double", "double"));
384-
verifyDataRows(actual, rows("2008-09-01 06:12:27", 1220249547.0, 3404817525d));
381+
schema("unix_timestamp", "double"),
382+
schema("unix_long", "double"),
383+
schema("unix_ms", "double"));
384+
verifyDataRows(actual, rows(1220249547.0, 3404817525.0, 1.220249547123456E9));
385385
}
386386

387387
@Test

0 commit comments

Comments
 (0)