Skip to content

Commit 6465ec8

Browse files
Addressed Some PR Comments
Signed-off-by: GabeFernandez310 <gabrielf@bitquilltech.com>
1 parent 4d4afa5 commit 6465ec8

1 file changed

Lines changed: 10 additions & 6 deletions

File tree

core/src/main/java/org/opensearch/sql/expression/datetime/DateTimeFunction.java

Lines changed: 10 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@
2020
import static org.opensearch.sql.expression.function.FunctionDSL.impl;
2121
import static org.opensearch.sql.expression.function.FunctionDSL.implWithProperties;
2222
import static org.opensearch.sql.expression.function.FunctionDSL.nullMissingHandling;
23+
import static org.opensearch.sql.expression.function.FunctionDSL.nullMissingHandlingWithProperties;
2324
import static org.opensearch.sql.utils.DateTimeFormatters.DATE_FORMATTER_LONG_YEAR;
2425
import static org.opensearch.sql.utils.DateTimeFormatters.DATE_FORMATTER_SHORT_YEAR;
2526
import static org.opensearch.sql.utils.DateTimeFormatters.DATE_TIME_FORMATTER_LONG_YEAR;
@@ -371,8 +372,9 @@ private DefaultFunctionResolver dayOfWeek() {
371372
*/
372373
private DefaultFunctionResolver dayOfYear(BuiltinFunctionName dayOfYear) {
373374
return define(dayOfYear.getName(),
374-
implWithProperties((functionProperties, arg) -> DateTimeFunction.dayOfYearToday(
375-
functionProperties.getQueryStartClock()), INTEGER, TIME),
375+
implWithProperties(nullMissingHandlingWithProperties((functionProperties, arg)
376+
-> DateTimeFunction.dayOfYearToday(
377+
functionProperties.getQueryStartClock())), INTEGER, TIME),
376378
impl(nullMissingHandling(DateTimeFunction::exprDayOfYear), INTEGER, DATE),
377379
impl(nullMissingHandling(DateTimeFunction::exprDayOfYear), INTEGER, DATETIME),
378380
impl(nullMissingHandling(DateTimeFunction::exprDayOfYear), INTEGER, TIMESTAMP),
@@ -446,8 +448,9 @@ private DefaultFunctionResolver minute() {
446448
*/
447449
private DefaultFunctionResolver month(BuiltinFunctionName month) {
448450
return define(month.getName(),
449-
implWithProperties((functionProperties, arg) -> DateTimeFunction.monthOfYearToday(
450-
functionProperties.getQueryStartClock()), INTEGER, TIME),
451+
implWithProperties(nullMissingHandlingWithProperties((functionProperties, arg)
452+
-> DateTimeFunction.monthOfYearToday(
453+
functionProperties.getQueryStartClock())), INTEGER, TIME),
451454
impl(nullMissingHandling(DateTimeFunction::exprMonth), INTEGER, DATE),
452455
impl(nullMissingHandling(DateTimeFunction::exprMonth), INTEGER, DATETIME),
453456
impl(nullMissingHandling(DateTimeFunction::exprMonth), INTEGER, TIMESTAMP),
@@ -609,9 +612,10 @@ private DefaultFunctionResolver utc_timestamp() {
609612
*/
610613
private DefaultFunctionResolver week(BuiltinFunctionName week) {
611614
return define(week.getName(),
612-
implWithProperties((functionProperties, arg) -> DateTimeFunction.weekOfYearToday(
615+
implWithProperties(nullMissingHandlingWithProperties((functionProperties, arg)
616+
-> DateTimeFunction.weekOfYearToday(
613617
DEFAULT_WEEK_OF_YEAR_MODE,
614-
functionProperties.getQueryStartClock()), INTEGER, TIME),
618+
functionProperties.getQueryStartClock())), INTEGER, TIME),
615619
impl(nullMissingHandling(DateTimeFunction::exprWeekWithoutMode), INTEGER, DATE),
616620
impl(nullMissingHandling(DateTimeFunction::exprWeekWithoutMode), INTEGER, DATETIME),
617621
impl(nullMissingHandling(DateTimeFunction::exprWeekWithoutMode), INTEGER, TIMESTAMP),

0 commit comments

Comments
 (0)