use entryset

This commit is contained in:
Zoltan Haindrich 2024-07-19 15:13:17 +00:00
parent b38935a450
commit f7247e1bb7
2 changed files with 28 additions and 3 deletions

View File

@ -31,6 +31,7 @@ import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient; import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients; import org.apache.http.impl.client.HttpClients;
import java.util.Map.Entry;
import java.util.Properties; import java.util.Properties;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -82,9 +83,10 @@ public class Launcher
{ {
String quidemUri = System.getProperty(QUIDEM_URI, "druidtest:///"); String quidemUri = System.getProperty(QUIDEM_URI, "druidtest:///");
Properties p = System.getProperties(); Properties p = System.getProperties();
for (Object string : p.keySet()) { for (Entry<Object, Object> entry : p.entrySet()) {
if (string.toString().startsWith("quidem")) { Object key = entry.getKey();
log.info("[%s] -> %s", string, p.get(string)); if (key.toString().startsWith("quidem")) {
log.info("[%s] -> %s", key, entry.getValue());
} }
} }
log.info("Starting Quidem with URI[%s]", quidemUri); log.info("Starting Quidem with URI[%s]", quidemUri);

View File

@ -216,6 +216,29 @@ public class CalciteTableAppendTest extends BaseCalciteQueryTest
.run(); .run();
} }
@Test
public void testAppendCompatibleColumns2()
{
// dim3 has different type (string/long) in foo/foo2
testBuilder()
.sql("select u.dim3,f.dim3 from TABLE(APPEND('foo','foo')) u join foo f on u.dim3 is not distinct from f.dim3")
.expectedResults(
ResultMatchMode.RELAX_NULLS,
ImmutableList.of(
new Object[] {"11"},
new Object[] {"12"},
new Object[] {"10"},
new Object[] {"[\"a\",\"b\"]"},
new Object[] {"[\"b\",\"c\"]"},
new Object[] {"d"},
new Object[] {""},
new Object[] {null},
new Object[] {null}
)
)
.run();
}
@Test @Test
public void testAppendNoTableIsInvalid() public void testAppendNoTableIsInvalid()
{ {