minor

Author: ArnoMicrosoft

articles/synapse-analytics/synapse-link/concept-synapse-link-cosmos-db-support.md

@@ -1,5 +1,5 @@
 ---
-title: Azure Synapse Link for Cosmos DB supported features
+title: Azure Synapse Link for Azure Cosmos DB supported features
 description: Understand the current list of actions supported by Azure Synapse Link for Cosmos DB
 services: synapse-analytics 
 author: ArnoMicrosoft
@@ -26,7 +26,7 @@ You can connect to Cosmos DB container without enabling Synapse Link, in which c
 Here is list of the currently supported features within Synapse Link for Cosmos DB. 
 
 | Category              | Description |[Spark](https://docs.microsoft.com/azure/synapse-analytics/sql/on-demand-workspace-overview) | [SQL serverless](https://docs.microsoft.com/azure/synapse-analytics/sql/on-demand-workspace-overview) |
-| :-------------------- | :----------------------------------------------------------- |:----------------------------------------------------------- | :----------------------------------------------------------- | :----------------------------------------------------------- |
+| -------------------- | ----------------------------------------------------------- |----------------------------------------------------------- | ----------------------------------------------------------- | ----------------------------------------------------------- |
 | **Run-time Support** |Support for read or write by Azure Synapse run-time| ✓ | [Contact Us](mailto:[email protected]?subject=[Enable%20Preview%20Feature]%20SQL%20serverless%20for%20Cosmos%20DB)|
 | **Cosmos DB API support** |API support as a Synapse Link| SQL / Mongo DB | SQL / Mongo DB |
 | **Object**  |Objects such as table that can be created, pointing directly to Azure Cosmos DB container| View, Table | View |

articles/synapse-analytics/synapse-link/how-to-query-analytical-store-spark.md

@@ -1,5 +1,5 @@
 ---
-title: Query Cosmos DB analytical with Synapse Spark
+title: Query Azure Cosmos DB analytical store with Synapse Spark
 description: How to query Cosmos DB analytical with Synapse Spark
 services: synapse-analytics 
 author: ArnoMicrosoft
@@ -11,7 +11,7 @@ ms.author: acomet
 ms.reviewer: jrasnick
 ---
 
-# Query Cosmos DB analytical with Synapse Spark
+# Query Azure Cosmos DB analytical store with Synapse Spark
 
 This article gives some examples on how you can interact with the analytical store from Synapse gestures. Those gestures are visible when you right-click on a container. With gestures, you can quickly generate code and tweak it to your needs. They are also perfect for discovering data with a single click.
 
@@ -30,6 +30,16 @@ df = spark.read.format("cosmos.olap")\
 ​df.show(10)
 ```
 
+The equivalent code gesture in **Scala** would be the following code:
+```java
+// To select a preferred list of regions in a multi-region Cosmos DB account, add option("spark.cosmos.preferredRegions", "<Region1>,<Region2>")
+
+val df_olap = spark.read.format("cosmos.olap").
+    option("spark.synapse.linkedService", "pySparkSamplesDb").
+    option("spark.cosmos.container", "trafficSourceColl").
+    load()
+```
+
 ## Create Spark table
 
 In this gesture, you will create a Spark table pointing to the container you selected. That operation does not incur any data movement. If you decide to delete that table, the underlying container (and corresponding analytical store) won't be impacted. This scenario is convenient to reuse tables through third-party tools and provide accessibility to the data for the run-time.
@@ -60,6 +70,20 @@ YOURDATAFRAME.write.format("cosmos.oltp")\
     .save()
 ```
 
+The equivalent code gesture in **Scala** would be the following code:
+```java
+// To select a preferred list of regions in a multi-region Cosmos DB account, add option("spark.cosmos.preferredRegions", "<Region1>,<Region2>")
+
+import org.apache.spark.sql.SaveMode
+
+df.write.format("cosmos.oltp").
+    option("spark.synapse.linkedService", "pySparkSamplesDb").
+    option("spark.cosmos.container", "trafficSourceColl"). 
+    option("spark.cosmos.write.upsertEnabled", "true").
+    mode(SaveMode.Overwrite).
+    save()
+```
+
 ## Load streaming DataFrame from container
 In this gesture, you will use Spark Streaming capability to load data from a container into a dataframe. The data will be stored into the primary data lake account (and file system) that you connected to the workspace. If the folder /localReadCheckpointFolder is not created, it will be automatically created. This operation will impact the transactional performance of Cosmos DB.
 
@@ -77,6 +101,21 @@ dfStream = spark.readStream\
     .load()
 ```
 
+The equivalent code gesture in **Scala** would be the following code:
+```java
+// To select a preferred list of regions in a multi-region Cosmos DB account, add .option("spark.cosmos.preferredRegions", "<Region1>,<Region2>")
+
+val dfStream = spark.readStream.
+    format("cosmos.oltp").
+    option("spark.synapse.linkedService", "pySparkSamplesDb").
+    option("spark.cosmos.container", "trafficSourceColl").
+    option("spark.cosmos.changeFeed.readEnabled", "true").
+    option("spark.cosmos.changeFeed.startFromTheBeginning", "true").
+    option("spark.cosmos.changeFeed.checkpointLocation", "/localReadCheckpointFolder").
+    option("spark.cosmos.changeFeed.queryName", "streamTestRevin2").
+    load()
+```
+
 ## Write streaming DataFrame to container
 In this gesture, you will write a streaming dataframe into the Cosmos DB container you selected. If the folder /localReadCheckpointFolder is not created, it will be automatically created. This operation will impact the transactional performance of Cosmos DB.
 
@@ -94,4 +133,21 @@ streamQuery = dfStream\
         .start()
 
 streamQuery.awaitTermination()
+```
+
+The equivalent code gesture in **Scala** would be the following code:
+```java
+// To select a preferred list of regions in a multi-region Cosmos DB account, add .option("spark.cosmos.preferredRegions", "<Region1>,<Region2>")
+
+val query = dfStream.
+            writeStream.
+            format("cosmos.oltp").
+            outputMode("append").
+            option("checkpointLocation", "/localWriteCheckpointFolder").
+            option("spark.synapse.linkedService", "pySparkSamplesDb").
+            option("spark.cosmos.container", "test2").
+            option("spark.cosmos.connection.mode", "gateway").
+            start()
+
+query.awaitTermination()
 ```