我的拼图格式是id。JSON,其中id是弹性搜索的id,JSON我想放入弹性搜索。下面是它的一小段。
+---+--------------------+
|key| value|
+---+--------------------+
| 6|{"FirstName":"pra...|
| 3|{"FirstName":["as...|
| 5|{"FirstName":"pra...|
| 4|{"FirstName":["pr...|
+---+--------------------+我如何在Java中做到这一点呢?
发布于 2021-07-17 16:21:06
“”“
Dataset<Row> ds =spark.read().parquet(path);
JavaPairRDD<String, String> jpRDD = ds.toJavaRDD().mapToPair(new PairFunction<Row, String, String>() {
public Tuple2<String, String> call(Row row) throws Exception {
return new Tuple2<String, String>((String) row.get(0), (String) row.get(1));
}
});
JavaEsSpark.saveToEsWithMeta(jpRDD,pathofESIndice,ImmutableMap.of("es.input.json","true"));“”“
https://stackoverflow.com/questions/68409455
复制相似问题