Skip to content

Commit c64bea5

Browse files
committed
add test
Signed-off-by: Kai Huang <ahkcs@amazon.com>
1 parent 58f20d8 commit c64bea5

File tree

1 file changed

+29
-0
lines changed

1 file changed

+29
-0
lines changed

integ-test/src/test/java/org/opensearch/sql/calcite/remote/CalciteBinCommandIT.java

Lines changed: 29 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1037,4 +1037,33 @@ public void testBinWithNestedFieldWithExplicitProjection() throws IOException {
10371037
verifyDataRows(
10381038
result, rows("10-12"), rows("10-12"), rows("12-14"), rows("12-14"), rows("14-16"));
10391039
}
1040+
1041+
@Test
1042+
public void testBinWithEvalCreatedDottedFieldName() throws IOException {
1043+
JSONObject result =
1044+
executeQuery(
1045+
String.format(
1046+
"source=%s | eval `resource.temp` = 1 | bin"
1047+
+ " `resource.attributes.telemetry.sdk.version` span=2 | sort"
1048+
+ " `resource.attributes.telemetry.sdk.version`",
1049+
TEST_INDEX_TELEMETRY));
1050+
1051+
verifySchema(
1052+
result,
1053+
schema("resource.attributes.telemetry.sdk.enabled", null, "boolean"),
1054+
schema("resource.attributes.telemetry.sdk.language", null, "string"),
1055+
schema("resource.attributes.telemetry.sdk.name", null, "string"),
1056+
schema("resource.temp", null, "int"),
1057+
schema("severityNumber", null, "int"),
1058+
schema("resource.attributes.telemetry.sdk.version", null, "string"));
1059+
1060+
// Data column order: enabled, language, name, severityNumber, resource.temp, version
1061+
verifyDataRows(
1062+
result,
1063+
rows(true, "java", "opentelemetry", 9, 1, "10-12"),
1064+
rows(false, "python", "opentelemetry", 12, 1, "10-12"),
1065+
rows(true, "javascript", "opentelemetry", 9, 1, "12-14"),
1066+
rows(false, "go", "opentelemetry", 16, 1, "12-14"),
1067+
rows(true, "rust", "opentelemetry", 12, 1, "14-16"));
1068+
}
10401069
}

0 commit comments

Comments
 (0)