From 8f312d143a418c0d3a214427cc9487cdba218b77 Mon Sep 17 00:00:00 2001 From: Larry Booker Date: Mon, 24 Jun 2024 17:49:28 -0700 Subject: [PATCH] Corrected OOB test failures due to Iceberg API table column renames. (#5662) --- .../iceberg/util/IcebergToolsTest.java | 20 +++++++++---------- 1 file changed, 10 insertions(+), 10 deletions(-) diff --git a/extensions/iceberg/s3/src/test/java/io/deephaven/iceberg/util/IcebergToolsTest.java b/extensions/iceberg/s3/src/test/java/io/deephaven/iceberg/util/IcebergToolsTest.java index 7544976f27b..a2db0131879 100644 --- a/extensions/iceberg/s3/src/test/java/io/deephaven/iceberg/util/IcebergToolsTest.java +++ b/extensions/iceberg/s3/src/test/java/io/deephaven/iceberg/util/IcebergToolsTest.java @@ -118,8 +118,8 @@ public void testListNamespaces() { final Table table = adapter.listNamespacesAsTable(); Assert.eq(table.size(), "table.size()", 2, "2 namespace in the catalog"); - Assert.eqTrue(table.getColumnSource("namespace").getType().equals(String.class), "namespace column type"); - Assert.eqTrue(table.getColumnSource("namespace_object").getType().equals(Namespace.class), + Assert.eqTrue(table.getColumnSource("Namespace").getType().equals(String.class), "namespace column type"); + Assert.eqTrue(table.getColumnSource("NamespaceObject").getType().equals(Namespace.class), "namespace_object column type"); } @@ -138,9 +138,9 @@ public void testListTables() { Table table = adapter.listTablesAsTable(ns); Assert.eq(table.size(), "table.size()", 3, "3 tables in the namespace"); - Assert.eqTrue(table.getColumnSource("namespace").getType().equals(String.class), "namespace column type"); - Assert.eqTrue(table.getColumnSource("table_name").getType().equals(String.class), "table_name column type"); - Assert.eqTrue(table.getColumnSource("table_identifier_object").getType().equals(TableIdentifier.class), + Assert.eqTrue(table.getColumnSource("Namespace").getType().equals(String.class), "namespace column type"); + Assert.eqTrue(table.getColumnSource("TableName").getType().equals(String.class), "table_name column type"); + Assert.eqTrue(table.getColumnSource("TableIdentifierObject").getType().equals(TableIdentifier.class), "table_identifier_object column type"); // Test the string versions of the methods @@ -166,11 +166,11 @@ public void testListSnapshots() { Table table = adapter.listSnapshotsAsTable(tableIdentifier); Assert.eq(table.size(), "table.size()", 4, "4 snapshots for sales/sales_multi"); - Assert.eqTrue(table.getColumnSource("id").getType().equals(long.class), "id column type"); - Assert.eqTrue(table.getColumnSource("timestamp_ms").getType().equals(long.class), "timestamp_ms column type"); - Assert.eqTrue(table.getColumnSource("operation").getType().equals(String.class), "operation column type"); - Assert.eqTrue(table.getColumnSource("summary").getType().equals(Map.class), "summary column type"); - Assert.eqTrue(table.getColumnSource("snapshot_object").getType().equals(Snapshot.class), + Assert.eqTrue(table.getColumnSource("Id").getType().equals(long.class), "id column type"); + Assert.eqTrue(table.getColumnSource("TimestampMs").getType().equals(long.class), "timestamp_ms column type"); + Assert.eqTrue(table.getColumnSource("Operation").getType().equals(String.class), "operation column type"); + Assert.eqTrue(table.getColumnSource("Summary").getType().equals(Map.class), "summary column type"); + Assert.eqTrue(table.getColumnSource("SnapshotObject").getType().equals(Snapshot.class), "snapshot_object column type"); // Test the string versions of the methods