1

我正在使用 pyspark 将数据框写入弹性搜索。我能够获得 Kibana 中的字段。这里的问题是在 kibana 中,每当我引用一个在内容之间有空格的字符串列时,该字符串在图中显示为两个不同的字段。经过一些分析,我发现该字段必须在 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")

这就是我将数据框写入elasticsearch的方式。如何在此处指定字段的已分析或未分析属性?

4

0 回答 0