Skip to content

Commit 47d4189

Browse files
committed
add type checker
Signed-off-by: xinyual <xinyual@amazon.com>
1 parent 9cffad0 commit 47d4189

6 files changed

Lines changed: 36 additions & 0 deletions

File tree

core/src/main/java/org/opensearch/sql/expression/function/CollectionUDF/ArrayFunctionImpl.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import org.apache.calcite.sql.type.SqlReturnTypeInference;
2525
import org.apache.calcite.sql.type.SqlTypeName;
2626
import org.opensearch.sql.expression.function.ImplementorUDF;
27+
import org.opensearch.sql.expression.function.UDFOperandMetadata;
2728

2829
// TODO: Support array of mixture types.
2930
public class ArrayFunctionImpl extends ImplementorUDF {
@@ -51,6 +52,11 @@ public SqlReturnTypeInference getReturnTypeInference() {
5152
};
5253
}
5354

55+
@Override
56+
public UDFOperandMetadata getOperandMetadata() {
57+
return null;
58+
}
59+
5460
public static class ArrayImplementor implements NotNullImplementor {
5561
@Override
5662
public Expression implement(

core/src/main/java/org/opensearch/sql/expression/function/CollectionUDF/ExistsFunctionImpl.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
import org.apache.calcite.sql.type.ReturnTypes;
1818
import org.apache.calcite.sql.type.SqlReturnTypeInference;
1919
import org.opensearch.sql.expression.function.ImplementorUDF;
20+
import org.opensearch.sql.expression.function.UDFOperandMetadata;
2021

2122
public class ExistsFunctionImpl extends ImplementorUDF {
2223
public ExistsFunctionImpl() {
@@ -28,6 +29,11 @@ public SqlReturnTypeInference getReturnTypeInference() {
2829
return ReturnTypes.BOOLEAN;
2930
}
3031

32+
@Override
33+
public UDFOperandMetadata getOperandMetadata() {
34+
return null;
35+
}
36+
3137
public static class ExistsImplementor implements NotNullImplementor {
3238
@Override
3339
public Expression implement(

core/src/main/java/org/opensearch/sql/expression/function/CollectionUDF/FilterFunctionImpl.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,7 @@
1818
import org.apache.calcite.sql.type.ReturnTypes;
1919
import org.apache.calcite.sql.type.SqlReturnTypeInference;
2020
import org.opensearch.sql.expression.function.ImplementorUDF;
21+
import org.opensearch.sql.expression.function.UDFOperandMetadata;
2122

2223
public class FilterFunctionImpl extends ImplementorUDF {
2324
public FilterFunctionImpl() {
@@ -29,6 +30,11 @@ public SqlReturnTypeInference getReturnTypeInference() {
2930
return ReturnTypes.ARG0;
3031
}
3132

33+
@Override
34+
public UDFOperandMetadata getOperandMetadata() {
35+
return null;
36+
}
37+
3238
public static class FilterImplementor implements NotNullImplementor {
3339
@Override
3440
public Expression implement(

core/src/main/java/org/opensearch/sql/expression/function/CollectionUDF/ForallFunctionImpl.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717
import org.apache.calcite.sql.type.ReturnTypes;
1818
import org.apache.calcite.sql.type.SqlReturnTypeInference;
1919
import org.opensearch.sql.expression.function.ImplementorUDF;
20+
import org.opensearch.sql.expression.function.UDFOperandMetadata;
2021

2122
public class ForallFunctionImpl extends ImplementorUDF {
2223
public ForallFunctionImpl() {
@@ -28,6 +29,11 @@ public SqlReturnTypeInference getReturnTypeInference() {
2829
return ReturnTypes.BOOLEAN;
2930
}
3031

32+
@Override
33+
public UDFOperandMetadata getOperandMetadata() {
34+
return null;
35+
}
36+
3137
public static class ForallImplementor implements NotNullImplementor {
3238
@Override
3339
public Expression implement(

core/src/main/java/org/opensearch/sql/expression/function/CollectionUDF/ReduceFunctionImpl.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -28,6 +28,7 @@
2828
import org.apache.calcite.sql.type.SqlReturnTypeInference;
2929
import org.apache.calcite.sql.type.SqlTypeName;
3030
import org.opensearch.sql.expression.function.ImplementorUDF;
31+
import org.opensearch.sql.expression.function.UDFOperandMetadata;
3132

3233
public class ReduceFunctionImpl extends ImplementorUDF {
3334
public ReduceFunctionImpl() {
@@ -63,6 +64,11 @@ public SqlReturnTypeInference getReturnTypeInference() {
6364
};
6465
}
6566

67+
@Override
68+
public UDFOperandMetadata getOperandMetadata() {
69+
return null;
70+
}
71+
6672
public static class ReduceImplementor implements NotNullImplementor {
6773
@Override
6874
public Expression implement(

core/src/main/java/org/opensearch/sql/expression/function/CollectionUDF/TransformFunctionImpl.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import org.apache.calcite.sql.type.SqlReturnTypeInference;
2727
import org.apache.calcite.sql.type.SqlTypeName;
2828
import org.opensearch.sql.expression.function.ImplementorUDF;
29+
import org.opensearch.sql.expression.function.UDFOperandMetadata;
2930

3031
public class TransformFunctionImpl extends ImplementorUDF {
3132
public TransformFunctionImpl() {
@@ -44,6 +45,11 @@ public SqlReturnTypeInference getReturnTypeInference() {
4445
};
4546
}
4647

48+
@Override
49+
public UDFOperandMetadata getOperandMetadata() {
50+
return null;
51+
}
52+
4753
public static class TransformImplementor implements NotNullImplementor {
4854
@Override
4955
public Expression implement(

0 commit comments

Comments
 (0)