fix cases where function calls itself (#164)

apache · Jun 10, 2023 · 8daafcd · 8daafcd
1 parent 5fbd368
commit 8daafcd
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/...e/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala b/...e/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala
@@ -33,7 +33,7 @@ object BigQueryArrowStorage {
   def readRecordsMerged(projectId: String,
       datasetId: String,
       tableId: String): Source[java.util.List[BigQueryRecord], CompletionStage[NotUsed]] =
-    readRecordsMerged(projectId, datasetId, tableId)
+    readRecordsMerged(projectId, datasetId, tableId, None, 0)
 
   def readRecordsMerged(projectId: String,
       datasetId: String,
@@ -72,7 +72,7 @@ object BigQueryArrowStorage {
   def readRecords(projectId: String,
       datasetId: String,
       tableId: String): Source[java.util.List[Source[BigQueryRecord, NotUsed]], CompletionStage[NotUsed]] =
-    readRecords(projectId, datasetId, tableId)
+    readRecords(projectId, datasetId, tableId, None, 0)
 
   def readRecords(
       projectId: String,
@@ -114,7 +114,7 @@ object BigQueryArrowStorage {
   def readMerged(projectId: String,
       datasetId: String,
       tableId: String): Source[(ArrowSchema, Source[ArrowRecordBatch, NotUsed]), CompletionStage[NotUsed]] =
-    readMerged(projectId, datasetId, tableId)
+    readMerged(projectId, datasetId, tableId, None, 0)
 
   def readMerged(
       projectId: String,

diff --git a/...he/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala b/...he/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala
@@ -71,7 +71,7 @@ object BigQueryAvroStorage {
   def readRecords(projectId: String,
       datasetId: String,
       tableId: String): Source[java.util.List[Source[BigQueryRecord, NotUsed]], CompletionStage[NotUsed]] =
-    readRecords(projectId, datasetId, tableId)
+    readRecords(projectId, datasetId, tableId, None, 0)
 
   def readRecords(
       projectId: String,
@@ -113,7 +113,7 @@ object BigQueryAvroStorage {
   def readMerged(projectId: String,
       datasetId: String,
       tableId: String): Source[(AvroSchema, Source[AvroRows, NotUsed]), CompletionStage[NotUsed]] =
-    readMerged(projectId, datasetId, tableId)
+    readMerged(projectId, datasetId, tableId, None, 0)
 
   def readMerged(projectId: String,
       datasetId: String,