惯性聚合 高效追踪和阅读你感兴趣的博客、新闻、科技资讯
阅读原文 在惯性聚合中打开

推荐订阅源

J
Java Code Geeks
T
Tailwind CSS Blog
酷 壳 – CoolShell
酷 壳 – CoolShell
OSCHINA 社区最新新闻
OSCHINA 社区最新新闻
L
LangChain Blog
博客园 - 【当耐特】
I
InfoQ
腾讯CDC
人人都是产品经理
人人都是产品经理
H
Help Net Security
Y
Y Combinator Blog
B
Blog
博客园 - Franky
Microsoft Security Blog
Microsoft Security Blog
Stack Overflow Blog
Stack Overflow Blog
The Cloudflare Blog
让小产品的独立变现更简单 - ezindie.com
让小产品的独立变现更简单 - ezindie.com
WordPress大学
WordPress大学
H
Hackread – Cybersecurity News, Data Breaches, AI and More
博客园 - 叶小钗
D
Docker
博客园 - 聂微东
B
Blog RSS Feed
G
Google Developers Blog

祈雨的笔记

安全多方计算MPC spark原理解析 kueue执行源码分析 spark on k8s执行源码分析 spark-operator源码解析 系统压测遇到的缓存击穿问题 我的世界PC与安卓联机 蚂蚁金服流量投放平台的AIG改造 G1大对象致Old区占用率高 日志打印导致接口响应率下跌分析 Groovy加载类导致OOM分析 ERROR日志打印导致CPU满载 记OceanBase死锁超时 应用发版期间服务响应超时 Ark Serverless初探 系统优化复盘一二三 The user specified as a definer does not exist Kong网关初探 API网关选型调研 CPU火焰图常用工具 配置中心选型调研 root操作Nginx导致用户组错误 基于Proxifier使用代理 FastJSON字段智能匹配踩坑 Nacos初探 记一次Nginx服务器CPU满荷载故障 基于券系统分库分表的思考 limit不参与SQL成本计算致索引失效 Linux常用性能监控命令 golang低版本http2偶现400
lucene5(1)简单示例
祈雨的笔记 · 2017-10-01 · via 祈雨的笔记

NO BIBI亮代码

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
private IndexWriter writer;
private IndexReader reader;

private static final String INDEX_DIR = "E:/LuceneIndex";



public IndexWriter getIndexWriter(String indexDir) throws Exception {
if (writer == null) {
Analyzer analyzer = getAnalyzer();
IndexWriterConfig writerConfig = new IndexWriterConfig(analyzer);


Directory directory = FSDirectory.open(Paths.get(indexDir));
writer = new IndexWriter(directory, writerConfig);
}
return writer;
}




public IndexReader getIndexReader(String indexDir) throws IOException {
if (reader == null) {
Directory directory = FSDirectory.open(Paths.get(indexDir));
reader = DirectoryReader.open(directory);

System.out.println("当前存储的文档数:" + reader.numDocs());
System.out.println("当前存储的文档数,包含回收站的文档:" + reader.maxDoc());
System.out.println("回收站的文档数:" + reader.numDeletedDocs());
}
return reader;
}




public void close() throws Exception {
writer.close();
reader.close();
}




private Analyzer getAnalyzer(){
return new StandardAnalyzer();
}

@Test
public void testWriter() throws Exception {
IndexWriter writer = getIndexWriter(INDEX_DIR);
Document document = new Document();

document.add(new TextField("name", "hello world", Field.Store.YES));
document.add(new TextField("describes", "测试luence", Field.Store.YES));

writer.addDocument(document);
writer.close();
}

@Test
public void testReader() throws Exception {
IndexReader reader = getIndexReader(INDEX_DIR);
IndexSearcher searcher = new IndexSearcher(reader);

QueryParser parser = new QueryParser("describes", getAnalyzer());

Query query = parser.parse("试");

TopDocs hits = searcher.search(query, 10);
for (ScoreDoc sd : hits.scoreDocs) {
Document doc = searcher.doc(sd.doc);
System.out.println(doc.get("name") + "[describes]=" + doc.get("describes"));
}
reader.close();
}