你的浏览器禁用了JavaScript, 请开启后刷新浏览器获得更好的体验!
发现
分享
文章
活动
登录
疲劳是最舒适的枕头,努力工作吧。
spark导入数据到elasticsearch如何指定默认的id
Elasticsearch
| 作者
datadog
| 发布于2019年09月10日 | 阅读数:
3381
分享到:
QQ空间
新浪微博
微信
QQ好友
印象笔记
有道云笔记
如题,目前通过sparkstreaming实时处理数据之后将数据保存在elasticsearch,如过想指定文档_id默认为时间戳,需要如何设定呢?(是通过_mapping设置吗?)我们是用java或者python的,目前没有找到样例,求大神指导一下。
没有找到相关结果
已邀请:
与内容相关的链接
提交
1 个回复
wuqi55777
赞同来自:
可参考下。
/** * 功能描述:插入数据(指定id)
* @param index 索引名
* @param type 类型
* @param _id 数据id
* @param json 数据
*/
public boolean insertData(String index, String type, String _id, String json) {
int status = getTransportClient().prepareIndex(index, type).setId(_id).setSource( json).get().status().getStatus();
if(status == RestStatus.CREATED.getStatus())
{
return true;
}else{
return false;
}
}
要回复问题请先
登录
或
注册
发起人
datadog
大数据开发,数据分析,数据挖掘的农民工
活动推荐
Aug
15
2025 Zabbix 中国峰会
上海
·
8-15 周五
·
报名中
Oct
17
第27届 GOPS 全球运维大会暨研运数智化技术峰会 · 上海站
上海
·
10-17 周五
·
报名中
相关问题
3千万数据,如何设计集群
elasticsearch scroll查询的原理没太懂
我来写第一个帖子-你们都是什么时候知道elasticsearch的?
怎么解决elasticsearch集群占用太多虚拟内存(VIRT)的问题?占用了几十个G,有什么可以对它进行限制的相关设置吗?
elasticsearch 设置 node.data: false 依然有数据
集群稳定性的一些问题(一定量数据后集群变得迟钝)
ElasticSearch-Hadoop的目標是什麼呢??
elasticsearch functionScoreQuery scriptFunction效率问题
跨集群数据同步方案讨论
Elastic对类似枚举数据的搜索性能优化
请教elasticsearch出现unassigned shards根本原因
问题状态
最新活动:
2019-09-11 10:23
浏览:
3381
关注:
2
人
1 个回复
wuqi55777
赞同来自:
/** * 功能描述:插入数据(指定id)
* @param index 索引名
* @param type 类型
* @param _id 数据id
* @param json 数据
*/
public boolean insertData(String index, String type, String _id, String json) {
int status = getTransportClient().prepareIndex(index, type).setId(_id).setSource( json).get().status().getStatus();
if(status == RestStatus.CREATED.getStatus())
{
return true;
}else{
return false;
}
}