You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pekko.apache.org by fa...@apache.org on 2023/06/10 16:13:07 UTC
[incubator-pekko-connectors] branch main updated: fix cases where function calls itself (#164)
This is an automated email from the ASF dual-hosted git repository.
fanningpj pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-pekko-connectors.git
The following commit(s) were added to refs/heads/main by this push:
new 8daafcd0f fix cases where function calls itself (#164)
8daafcd0f is described below
commit 8daafcd0f9356dc2d60fb2848ad0e4a9e78865e2
Author: PJ Fanning <pj...@users.noreply.github.com>
AuthorDate: Sat Jun 10 17:13:02 2023 +0100
fix cases where function calls itself (#164)
---
.../googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala | 6 +++---
.../googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala | 4 ++--
2 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala
index a65d51018..e2bd1a819 100644
--- a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryArrowStorage.scala
+++ b/google-cloud-bigquery-storage/src/main/scala/org/apache/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/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala b/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala
index 515760004..5c69d78b2 100644
--- a/google-cloud-bigquery-storage/src/main/scala/org/apache/pekko/stream/connectors/googlecloud/bigquery/storage/javadsl/BigQueryAvroStorage.scala
+++ b/google-cloud-bigquery-storage/src/main/scala/org/apache/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,
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pekko.apache.org
For additional commands, e-mail: commits-help@pekko.apache.org