Skip to content

Commit fc6dd27

Browse files
committed
Add geoip of string override because the udt type is erased during validation (1884/2028)
Signed-off-by: Yuanchun Shen <yuanchu@amazon.com>
1 parent a47ab44 commit fc6dd27

1 file changed

Lines changed: 6 additions & 1 deletion

File tree

opensearch/src/main/java/org/opensearch/sql/opensearch/functions/GeoIpFunction.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -101,10 +101,15 @@ public Expression implement(
101101
ExprIpValue ipAddress,
102102
String commaSeparatedOptions,
103103
NodeClient nodeClient) {
104+
return fetchIpEnrichment(dataSource, ipAddress.toString(), commaSeparatedOptions, nodeClient);
105+
}
106+
107+
public static Map<String, ?> fetchIpEnrichment(
108+
String dataSource, String ipAddress, String commaSeparatedOptions, NodeClient nodeClient) {
104109
String unquotedOptions = StringUtils.unquoteText(commaSeparatedOptions);
105110
final Set<String> options =
106111
Arrays.stream(unquotedOptions.split(",")).map(String::trim).collect(Collectors.toSet());
107-
return fetchIpEnrichment(dataSource, ipAddress.toString(), options, nodeClient);
112+
return fetchIpEnrichment(dataSource, ipAddress, options, nodeClient);
108113
}
109114

110115
private static Map<String, ?> fetchIpEnrichment(

0 commit comments

Comments
 (0)