匿名用户elasticsearch 到file，设置为多线程导出，想让每个线程单独一个文件，FilenameGenerator里怎么获取和线程相关的信息？
elasticsearch 到file，设置为多线程导出，想让每个线程单独一个文件，FilenameGenerator里怎么获取和线程相关的信息？
我来答
添加附件
收藏
分享
问题补充
1条回答
默认
最新
可以写个接口方法
public class CustomFilenameGenerator implements FilenameGenerator {
@Override
public String generateFilename() {
String currentThreadName = Thread.currentThread().getName();
String filename = "data_" + currentThreadName + ".txt";
return filename;
}
}
评论
有用 0 打赏 0
回答交流
Markdown
请输入正文
提交
相关推荐
logstash 每秒都会同步 sql能查询出数据 但是就是不往elasticsearch插入?
回答 2
手工给es写几条看看能不能写入？是不是配置错了，看看报错日志。
Elasticsearch 怎么同步mysql里面的数据？
回答 2
可以使用kafka之类的中间件，先将mysql里的数据抽出来，再同步到es里。
Elasticserach里delete_by_query的机制是什么？
回答 1
https://www.elastic.co/guide/en/elasticsearch/reference/current/docsdeletebyquery.html彻底搞明白
logstash和elasticsearch的版本需要一致吗?
回答 2
已采纳
最好要保持一致，要不然有可能会遇到不兼容或者bug看看官网https://www.elastic.co/cn/support/matrixmatrixcompatibility
Elasticsearch没有集群就一个，状态是red,但是可以搜索到数据,为什么?
回答 1
3个节点都是好的才是绿色的。2个能用是黄色的。1个只能是红了。只是表示健康度，有点危险。不影响使用。
elasticsearch和logstash可以装一台服务器上吗？
回答 2
已采纳
只要服务器资源足够，完全没问题
springboot整合elasticsearch一般都是用IP+端口号，可以换成映射的域名链接吗?
回答 1
已采纳
spring.elasticsearch.rest.uriselasticsearch的ip:端口或elasticsearch域名
Elasticsearch 为什么几百万数据查询得好几秒?
回答 2
Elasticsearch会为每个field都建立了一个倒排索引，张三、李四、23、24…这些叫term，而[1,4]就是PostingList。Postinglist就是一个int的数组，存储了所有
elasticsearch可以基于聚合做searchafter吗？
回答 1
https://blog.csdn.net/ctwy291314/article/details/82754652
怎么根据es集群的数据量和主机配置来预估能支持多大的QPS？
回答 1
已采纳
这个没有相关性。就像如果说知道一个数据库的硬件配置和数据量。能获得MySQLoracleog的qps和iops吗？不能要看设计和实现方式。
