You have an Azure Cosmos DB account named Account1 that uses the SQL APL Account1 contains a collection named Coll1.
You have an Apache Spark cluster in Azure HDInsight. The duster is located in the same Azure region as Account1.
You configure a Spark to Cosmos DB connector to access Coll1.
You successfully use the following code to run non-aggregate queries from within a Spark session by using the connector (Line numbers are included for reference only.)
01 query= client QueryDocuments (
02 collLink, querystr,
03 options=
04 {
05 'enablecrossPartitionQuery': True
06 },
07 partition_key-None)
08 df = spark.createDataFrame(list(query))
You need to modify the code to ensure that you can run couNT aggregate quenes.
What should you do?