What should you do?

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?
A . Replace line 08 with the following code:
df – spark.createDataFrame (spark.sparkContext.parallelize (list (query))
B . Replace line 08 with the following code:
df – spark. createDataFrame (list(query), IntegerType ())
C . Replace fine OS with the following code:
‘enableCrossPartitilonQuery’: False
D . Replace line 05 with the following code.
‘enablescanInQuery’: True