Сумма массива словарей в зависимости от условия значения pyspark (spark structured streaming)

#apache-spark #pyspark #apache-spark-sql #spark-structured-streaming Вопрос: У меня есть следующая схема tick_by_tick_schema = StructType([ StructField('localSymbol', StringType()), StructField('time', StringType()), StructField('open', StringType()), StructField('previous_price', StringType()), StructField('tickByTicks', ArrayType(StructType([ StructField('price', StringType()), StructField('size', StringType()), StructField('specialConditions', StringType()), ])))…