spark-dataframe / mongo - добавить данные

Question

Мне нужно добавить данные в mongodb, используя spark-dataframe. Например, скажем, в портфеле 100 тыс. Акций:

Акция

• Янв 2018

  • Прибыль: $ 30 тыс.

Запас B

• январь 2018
  • Профиль: - $ 10k

MongoDB

_id: ObjectId('XXX1')

stock: Stock A

monthlyProfit: Array

    0: Object

        Month: Jan 2018

        Profit: 30k


_id: ObjectId('XXX2')

stock: Stock B

monthlyProfit: Array

    0: Object

        Month: Jan 2018

        Profit: -10k

Если бы мне пришлось добавить прибыль за февраль, как мне добавить элемент в существующий массив и отправить его в mongodb без проблем с производительностью, если для всех 100k документов в коллекции должны происходить одинаковые обновления?