AbsaOSS / AbsaOSS/spline-spark-agent

Azure Cosmos DB write operation support

Offen
#56 5 Kommentare 0 Reaktionen 0 zugewiesene Personen Auf GitHub ansehen
feature good first issue
Vorherrschende Sprache
Scala
Sterne
210
Forks
102
Ø Merge
1 T. 1 Std.
Gemergte PRs (30 T.)
1

Beschreibung

## Background
Spline is not able to track lineage while writing to Azure Cosmos DB

## Feature
Azure Cosmos DB write operation support

## Example
Sample Scala code of write operation to Cosmos DB, that is not able to track lineage

```scala
import com.microsoft.azure.cosmosdb.spark.schema._
import com.microsoft.azure.cosmosdb.spark.CosmosDBSpark
import com.microsoft.azure.cosmosdb.spark.config.Config
import org.apache.spark.sql.SaveMode

val customers_dataset_config_map = Map(
"Endpoint" -> "",
"Masterkey" -> dbutils.secrets.get(scope = "", key = ""),
"Database" -> "",
"Collection" -> "",
"WritingBatchSize" -> "100")

val customers_dataset_config = Config(customers_dataset_config_map)

// Write the output to Azure Cosmos DB
customers_dataset.write.mode(SaveMode.Overwrite).cosmosDB(customers_dataset_config)
```

Beitragsleitfaden

Für dieses Repository ist kein Beitragsleitfaden indexiert

Bewertung

Dieses Issue wurde noch nicht bewertet.

Neue Issues direkt in Ihr Postfach

Eine kurze Übersicht über anfängerfreundliche GitHub-Issues.