ок Е.С. Вопрос здесь

Каков рабочий процесс или шаги для передачи Spark Dataframe в Elastic Search?

Из исследований я считаю, что мне нужно использоватьspark.newAPIHadoopFile () метод.

Однако копаться вУпругая поисковая документация, а такжедругие стеки Q / A Я все еще немного запутался в том, в каком формате должны быть аргументы и почему

Обратите внимание, что я использую pyspark, это новая таблица для ES (индекс еще не существует), и df составляет 5 столбцов (2 строковых типа, 2 длинных типа и 1 список целых чисел) с ~ 3.5M строками.