Add Minute_Of_Hour Function As An Alias Of Minute Function

core/src/main/java/org/opensearch/sql/expression/DSL.java

@@ -354,6 +354,10 @@ public static FunctionExpression minute(Expression... expressions) {
     return compile(FunctionProperties.None, BuiltinFunctionName.MINUTE, expressions);
   }
 
+  public static FunctionExpression minute_of_hour(Expression... expressions) {
+    return compile(FunctionProperties.None, BuiltinFunctionName.MINUTE_OF_HOUR, expressions);
+  }
+
   public static FunctionExpression month(Expression... expressions) {
     return compile(FunctionProperties.None, BuiltinFunctionName.MONTH, expressions);
   }

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

@@ -112,7 +112,8 @@ public void register(BuiltinFunctionRepository repository) {
     repository.register(makedate());
     repository.register(maketime());
     repository.register(microsecond());
-    repository.register(minute());
+    repository.register(minute(BuiltinFunctionName.MINUTE));
+    repository.register(minute(BuiltinFunctionName.MINUTE_OF_HOUR));
     repository.register(month(BuiltinFunctionName.MONTH));
     repository.register(month(BuiltinFunctionName.MONTH_OF_YEAR));
     repository.register(monthName());
@@ -423,8 +424,8 @@ private DefaultFunctionResolver microsecond() {
   /**
    * MINUTE(STRING/TIME/DATETIME/TIMESTAMP). return the minute value for time.
    */
-  private DefaultFunctionResolver minute() {
-    return define(BuiltinFunctionName.MINUTE.getName(),
+  private DefaultFunctionResolver minute(BuiltinFunctionName name) {
+    return define(name.getName(),
         impl(nullMissingHandling(DateTimeFunction::exprMinute), INTEGER, STRING),
         impl(nullMissingHandling(DateTimeFunction::exprMinute), INTEGER, TIME),
         impl(nullMissingHandling(DateTimeFunction::exprMinute), INTEGER, DATETIME),

core/src/main/java/org/opensearch/sql/expression/function/BuiltinFunctionName.java

@@ -77,6 +77,7 @@ public enum BuiltinFunctionName {
   MAKETIME(FunctionName.of("maketime")),
   MICROSECOND(FunctionName.of("microsecond")),
   MINUTE(FunctionName.of("minute")),
+  MINUTE_OF_HOUR(FunctionName.of("minute_of_hour")),
   MONTH(FunctionName.of("month")),
   MONTH_OF_YEAR(FunctionName.of("month_of_year")),
   MONTHNAME(FunctionName.of("monthname")),

core/src/test/java/org/opensearch/sql/expression/datetime/DateTimeFunctionTest.java

@@ -691,6 +691,62 @@ public void minute() {
     assertEquals("minute(\"2020-08-17 01:02:03\")", expression.toString());
   }
 
+  public void testMinuteOfHour(FunctionExpression dateExpression, int minute, String testExpr) {
+    assertEquals(INTEGER, dateExpression.type());
+    assertEquals(integerValue(minute), eval(dateExpression));
+    assertEquals(testExpr, dateExpression.toString());
+  }
+
+  @Test
+  public void minuteOfHour() {
+    lenient().when(nullRef.valueOf(env)).thenReturn(nullValue());
+    lenient().when(missingRef.valueOf(env)).thenReturn(missingValue());
+
+    FunctionExpression expression1 = DSL.minute_of_hour(
+        DSL.literal(new ExprTimeValue("01:02:03")));
+    FunctionExpression expression2 = DSL.minute_of_hour(DSL.literal("01:02:03"));
+    FunctionExpression expression3 = DSL.minute_of_hour(
+        DSL.literal(new ExprTimestampValue("2020-08-17 01:02:03")));
+    FunctionExpression expression4 = DSL.minute_of_hour(
+        DSL.literal(new ExprDatetimeValue("2020-08-17 01:02:03")));
+    FunctionExpression expression5 = DSL.minute_of_hour(DSL.literal("2020-08-17 01:02:03"));
+
+
+    assertAll(
+        () -> testMinuteOfHour(expression1, 2, "minute_of_hour(TIME '01:02:03')"),
+        () -> testMinuteOfHour(expression2, 2, "minute_of_hour(\"01:02:03\")"),
+        () -> testMinuteOfHour(expression3, 2, "minute_of_hour(TIMESTAMP '2020-08-17 01:02:03')"),
+        () -> testMinuteOfHour(expression4, 2, "minute_of_hour(DATETIME '2020-08-17 01:02:03')"),
+        () -> testMinuteOfHour(expression5, 2, "minute_of_hour(\"2020-08-17 01:02:03\")")
+    );
+  }
+
+  public void testInvalidMinuteOfHour(String time) {
+    FunctionExpression expression = DSL.minute_of_hour(DSL.literal(new ExprTimeValue(time)));
+    eval(expression);
+  }
+
+  @Test
+  public void minuteOfHourInvalidArguments() {
+    when(nullRef.type()).thenReturn(TIME);
+    when(missingRef.type()).thenReturn(TIME);
+    assertEquals(nullValue(), eval(DSL.minute_of_hour(nullRef)));
+    assertEquals(missingValue(), eval(DSL.minute_of_hour(missingRef)));
+
+    //Invalid Seconds
+    assertThrows(SemanticCheckException.class, () -> testInvalidMinuteOfHour("12:23:61"));
+
+    //Invalid Minutes
+    assertThrows(SemanticCheckException.class, () -> testInvalidMinuteOfHour("12:61:34"));
+
+    //Invalid Hours
+    assertThrows(SemanticCheckException.class, () -> testInvalidMinuteOfHour("25:23:34"));
+
+    //incorrect format
+    assertThrows(SemanticCheckException.class, () -> testInvalidMinuteOfHour("asdfasdf"));
+  }
+
+
   @Test
   public void month() {
     when(nullRef.type()).thenReturn(DATE);

docs/user/dql/functions.rst

@@ -1747,6 +1747,7 @@ Description
 >>>>>>>>>>>
 
 Usage: minute(time) returns the minute for time, in the range 0 to 59.
+The `minute_of_hour` function is provided as an alias.
 
 Argument type: STRING/TIME/DATETIME/TIMESTAMP
 
@@ -1762,6 +1763,37 @@ Example::
     | 2                           |
     +-----------------------------+
 
+    os> SELECT MINUTE_OF_HOUR((TIME '01:02:03'))
+    fetched rows / total rows = 1/1
+    +-------------------------------------+
+    | MINUTE_OF_HOUR((TIME '01:02:03'))   |
+    |-------------------------------------|
+    | 2                                   |
+    +-------------------------------------+
+
+    os> SELECT MINUTE_OF_HOUR((TIME '01:02:03'))
+    fetched rows / total rows = 1/1
+    +-------------------------------------+
+    | MINUTE_OF_HOUR((TIME '01:02:03'))   |
+    |-------------------------------------|
+    | 2                                   |
+    +-------------------------------------+
+
+    os> SELECT MINUTE_OF_HOUR(datetime('2022-12-20 01:02:03'))
+    fetched rows / total rows = 1/1
+    +---------------------------------------------------+
+    | MINUTE_OF_HOUR(datetime('2022-12-20 01:02:03'))   |
+    |---------------------------------------------------|
+    | 2                                                 |
+    +---------------------------------------------------+
+
+    os> SELECT MINUTE_OF_HOUR((TIMESTAMP '2022-12-20 01:02:03'))
+    fetched rows / total rows = 1/1
+    +-----------------------------------------------------+
+    | MINUTE_OF_HOUR((TIMESTAMP '2022-12-20 01:02:03'))   |
+    |-----------------------------------------------------|
+    | 2                                                   |
+    +-----------------------------------------------------+
 
 MONTH
 -----

integ-test/src/test/java/org/opensearch/sql/sql/DateTimeFunctionIT.java

@@ -364,6 +364,52 @@ public void testMinute() throws IOException {
     verifyDataRows(result, rows(30));
   }
 
+  @Test
+  public void testMinuteOfHour() throws IOException {
+    JSONObject result = executeQuery("select minute_of_hour(timestamp('2020-09-16 17:30:00'))");
+    verifySchema(result, schema(
+        "minute_of_hour(timestamp('2020-09-16 17:30:00'))", null, "integer"));
+    verifyDataRows(result, rows(30));
+
+    result = executeQuery("select minute_of_hour(time('17:30:00'))");
+    verifySchema(result, schema("minute_of_hour(time('17:30:00'))", null, "integer"));
+    verifyDataRows(result, rows(30));
+
+    result = executeQuery("select minute_of_hour('2020-09-16 17:30:00')");
+    verifySchema(result, schema("minute_of_hour('2020-09-16 17:30:00')", null, "integer"));
+    verifyDataRows(result, rows(30));
+
+    result = executeQuery("select minute_of_hour('17:30:00')");
+    verifySchema(result, schema("minute_of_hour('17:30:00')", null, "integer"));
+    verifyDataRows(result, rows(30));
+  }
+
+  @Test
+  public void testMinuteFunctionAliasesReturnTheSameResults() throws IOException {
+    JSONObject result1 = executeQuery("SELECT minute('11:30:00')");
+    JSONObject result2 = executeQuery("SELECT minute_of_hour('11:30:00')");
+    verifyDataRows(result1, rows(30));
+    result1.getJSONArray("datarows").similar(result2.getJSONArray("datarows"));
+
+    result1 = executeQuery(String.format(
+        "SELECT minute(datetime(CAST(time0 AS STRING))) FROM %s", TEST_INDEX_CALCS));
+    result2 = executeQuery(String.format(
+        "SELECT minute_of_hour(datetime(CAST(time0 AS STRING))) FROM %s", TEST_INDEX_CALCS));
+    result1.getJSONArray("datarows").similar(result2.getJSONArray("datarows"));
+
+    result1 = executeQuery(String.format(
+        "SELECT minute(CAST(time0 AS STRING)) FROM %s", TEST_INDEX_CALCS));
+    result2 = executeQuery(String.format(
+        "SELECT minute_of_hour(CAST(time0 AS STRING)) FROM %s", TEST_INDEX_CALCS));
+    result1.getJSONArray("datarows").similar(result2.getJSONArray("datarows"));
+
+    result1 = executeQuery(String.format(
+        "SELECT minute(CAST(datetime0 AS timestamp)) FROM %s", TEST_INDEX_CALCS));
+    result2 = executeQuery(String.format(
+        "SELECT minute_of_hour(CAST(datetime0 AS timestamp)) FROM %s", TEST_INDEX_CALCS));
+    result1.getJSONArray("datarows").similar(result2.getJSONArray("datarows"));
+  }
+
   @Test
   public void testMonth() throws IOException {
     JSONObject result = executeQuery("select month(date('2020-09-16'))");

sql/src/main/antlr/OpenSearchSQLParser.g4

@@ -247,6 +247,7 @@ datetimeConstantLiteral
     | DAY_OF_YEAR
     | LOCALTIME
     | LOCALTIMESTAMP
+    | MINUTE_OF_HOUR
     | MONTH_OF_YEAR
     | UTC_TIMESTAMP
     | UTC_DATE

sql/src/test/java/org/opensearch/sql/sql/antlr/SQLSyntaxParserTest.java

@@ -203,6 +203,15 @@ public void can_parse_dayofyear_functions() {
     assertNotNull(parser.parse("SELECT day_of_year('2022-11-18')"));
   }
 
+  @Test
+  public void can_parse_minute_functions() {
+    assertNotNull(parser.parse("SELECT minute('12:23:34')"));
+    assertNotNull(parser.parse("SELECT minute_of_hour('12:23:34')"));
+
+    assertNotNull(parser.parse("SELECT minute('2022-12-20 12:23:34')"));
+    assertNotNull(parser.parse("SELECT minute_of_hour('2022-12-20 12:23:34')"));
+  }
+
   @Test
   public void can_parse_month_of_year_function() {
     assertNotNull(parser.parse("SELECT month('2022-11-18')"));