added support for pat authentication

qwshen · Nov 13, 2022 · 68fe86c · 68fe86c
1 parent a17119f
commit 68fe86c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/main/java/com/qwshen/flight/spark/read/FlightScanBuilder.java b/src/main/java/com/qwshen/flight/spark/read/FlightScanBuilder.java
@@ -75,7 +75,7 @@ public boolean pushAggregation(Aggregation aggregation) {
                 push = false;
                 break;
             }
-        };
+        }
         if (push) {
             String[] pdGroupByColumns = Arrays.stream(aggregation.groupByColumns()).flatMap(gbc -> Arrays.stream(gbc.fieldNames()).map(quote)).toArray(String[]::new);
             pdAggregateColumns.addAll(0, Arrays.asList(pdGroupByColumns));
@@ -135,7 +135,7 @@ public void pruneColumns(StructType columns) {
 
     /**
      * To build a flight-scan
-     * @return - A fligh scan
+     * @return - A flight scan
      */
     @Override
     public Scan build() {

diff --git a/src/test/scala/com/qwshen/flight/spark/test/DremioTest.scala b/src/test/scala/com/qwshen/flight/spark/test/DremioTest.scala
@@ -76,7 +76,7 @@ class DremioTest extends FunSuite with BeforeAndAfterEach {
         |  cast(3423.23 as float) as float_amount,
         |  cast(2342345.13 as double) as double_amount,
         |  cast(32423423.31 as decimal) as decimal_amount
-        |from "azure-wstorage".input.events e inner join "azure-wstorage".input.users u on e.user_id = u.user_id
+        |from "@test".events e inner join "@test".users u on e.user_id = u.user_id
       |""".stripMargin
     val run: SparkSession => DataFrame = this.load(Map("table" -> query, "column.quote" -> "\""))
     val df = this.execute(run)