Azure synapse change data capture

gistfile1.txt

import com.microsoft.azure.cosmos.analytics.spark.connector.datasource.CosmosOlapCDC

val configuration = Map(
  "spark.cosmos.accountEndpoint" -> "https://spark-perf.documents.azure.com:443/",
  "spark.cosmos.accountKey" -> "xxx",
  "spark.cosmos.database" -> "cdc",
  "spark.cosmos.container" -> "product",
  "spark.cosmos.cdc" -> "true",
  "spark.cosmos.cdc.initialRun" -> "true",
   "spark.cosmos.cdc.fullFidelity" -> "false",
   "spark.cosmos.cdc.keepUserDeletes" -> "true",
   "spark.cosmos.cdc.keepTtlDeletes" -> "true"
)

val cdcSnapshotMetadata = CosmosOlapCDC.initializeSnapshotRead(configuration)
val cdcDf = CosmosOlapCDC.createIncrementalSnapshot(cdcSnapshotMetadata)
display(cdcDf)