AbsaOSS / AbsaOSS/spline-spark-agent

Lineage Calculation not triggered when using Spark Connector for SQL Server BulkCopy API

オープン
#58 コメント 3 件 リアクション 0 件 担当者 1 名 @cerveada が担当を希望しています GitHub で見る
feature
主要言語
Scala
スター
210
フォーク
102
平均マージ
1日 1時間
マージ済み PR(30日)
1

説明

When using the Spark Sql Server connector (https://github.com/Azure/azure-sqldb-spark), there are two ways to produce the final output:

One way the Spark SQL Connectior API works is by using the usual df.write style operation which triggers lineage via the "Save" action (see example below)

However, when calling df.bulkCopyToSqlDB (also shown below), no lineage is triggered as no action is produced at all by the bulkCopyToSqlDB method as it doesn't go through the usual .jdbc chain. Is there a way to force Spline to produce the lineage for the bulkCopyToSqlDB "terminal" operation?

val df = ...//Read from wherever

//Using the Spark Sql Server connector
val writeConfig = Config(Map(
"url" -> "databaseservername",
"databaseName" -> "catalogname",
"dbTable" -> "tablename",
"user" -> "user",
"password" -> "password"
))

//This is the Spark Sql Server connector API using the usual write technique.
df.write.mode(SaveMode.Append).sqlDB(writeConfig) //Lineage gets triggered

//Spark Sql Connector also allows for a custom bulk copy that doesn't go through .jdbc
df.bulkCopyToSqlDB(writeConfig) //No action and as a result no lineage

Thanks,
Harish.

コントリビューションガイド

このリポジトリのコントリビューションガイドは索引されていません

評価

この issue はまだ評価されていません。

新しい issue をメールで受け取る

初心者向けの GitHub issue を短くまとめたダイジェスト。