Как изменить индексное поле, которое не анализируется в упругом поиске при записи фрейма данных?

Я пишу фрейм данных в asticsearch, используя pyspark. Я могу получить поля в Кибане. Проблема здесь в кибане всякий раз, когда я ссылаюсь на строковый столбец, который имеет пространство между содержимым, строка отображается в виде двух разных полей на графике. После некоторого анализа я обнаружил, что поле должно быть установлено как "не анализируемое" в ES, чтобы разделение не происходило.

dfcols = sqlContext.createDataFrame(cols)
dfcols.write.format("org.elasticsearch.spark.sql")\
.option("es.resource","index_name/sample")\
.option("es.nodes","http://server.qa.com")\
.option("es.port","9200")\
.save(mode="append")

Вот как я пишу свой фрейм данных в asticsearch. Как указать здесь анализируемое или не анализируемое свойство поля?

0 ответов

Другие вопросы по тегам