Merge pull request #2 from gopalldb/list-objects

Adding getObjects impl
gopalldb · Mar 14, 2024 · 3a3a224 · 3a3a224
2 parents 964d279 + d2fb852
commit 3a3a224
Show file tree

Hide file tree

Showing 2 changed files with 507 additions and 20 deletions.
diff --git a/csharp/src/Drivers/Apache/Hive2/HiveServer2Connection.cs b/csharp/src/Drivers/Apache/Hive2/HiveServer2Connection.cs
@@ -61,6 +61,7 @@ public void Open()
 
         public override IArrowArrayStream GetObjects(GetObjectsDepth depth, string catalogPattern, string dbSchemaPattern, string tableNamePattern, List<string> tableTypes, string columnNamePattern)
         {
+            Dictionary<string, Dictionary<string, Dictionary<string, List<string>>>> catalogMap = new Dictionary<string, Dictionary<string, Dictionary<string, List<string>>>>();
             if (depth == GetObjectsDepth.All || depth >= GetObjectsDepth.Catalogs)
             {
                 TGetCatalogsReq getCatalogsReq = new TGetCatalogsReq(this.sessionHandle);
@@ -73,7 +74,7 @@ public override IArrowArrayStream GetObjects(GetObjectsDepth depth, string catal
 
             if (depth == GetObjectsDepth.All || depth >= GetObjectsDepth.Tables)
             {
-                TGetTablesReq getSchemasReq = new TGetTablesReq(this.sessionHandle);
+                TGetTablesReq getTablesReq = new TGetTablesReq(this.sessionHandle);
             }
 
             if (depth == GetObjectsDepth.All)