首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

solr系列--solrj使用

solrj是solr的java客户端,用于访问solr索引库。它提供了添加、删除、查询、优化等功能。 配置jar: /dist/solrj-lib下的所有jar solr-solrj-5.2.1.jar server/lib/ext下所有jar 如果Maven来构建项目,添加以下代码到你的pom.xml配置文件中 <dependency>          <artifactId>solr-solrj</artifactId>          <groupId>org.apache.solr</groupId>          <version>1.4.0</version>          <type>jar</type>         <scope>compile</scope>  </dependency> <dependency>          <groupId>org.slf4j</groupId>         <artifactId>slf4j-simple</artifactId>         <version>1.5.6</version>  </dependency> @Test public void createIndex() throws Exception { // 创建HttpSolrClient // 参数:表示solr服务的访问基础URL HttpSolrClient server = new HttpSolrClient("http://localhost:8080/solr"); // 通过server添加SolrInputDocument SolrInputDocument doc = new SolrInputDocument(); doc.addField("id", "c001"); doc.addField("content_ik", "我爱传智播客22222"); server.add(doc); // 提交操作 server.commit(); } @Test public void deleteIndex() throws Exception { // 创建HttpSolrClient // 参数:表示solr服务的访问基础URL HttpSolrClient server = new HttpSolrClient("http://localhost:8080/solr"); // 通过id删除 // server.deleteById("c001"); // 根据查询条件删除 server.deleteByQuery("id:c001"); // 批量删除 server.deleteByQuery("*:*"); // 提交操作 server.commit(); } @Test public void search01() throws Exception { // 创建HttpSolrClient // 参数:表示solr服务的访问基础URL HttpSolrClient server = new HttpSolrClient("http://localhost:8080/solr"); // 创建查询对象 SolrQuery query = new SolrQuery(); // 设置查询条件 query.setQuery("*:*"); // 通过server查询,并返回结果 QueryResponse response = server.query(query); // 获取查询结果 SolrDocumentList results = response.getResults(); // 匹配出的所有商品记录 long count = results.getNumFound(); System.out.println("匹配出的所有商品记录:" + count); for (SolrDocument solrDocument : results) { System.out.println("商品ID:" + solrDocument.get("id")); System.out.println("商品名称:" + solrDocument.get("product_name")); System.out.println("商品分类名称:" + solrDocument.get("product_catalog_name")); System.out.println("商品价格:" + solrDocument.get("product_price")); Syste

01
您找到你想要的搜索结果了吗?
是的
没有找到

WHC RPC业务解析

wormholed-cli getrawtransaction "txid": 获取指定交易哈希的16进制交易数据 wormholed-cli decoderawtransaction "rawtx": 对获取到的16进制数据进行解码 wormholed-cli signrawtransaction "rawtx": 对原始交易进行签名 wormholed-cli sendrawtransaction "rawtx": 发送签名后的交易 wormholed-cli listunspent (成熟度0, 1 ...): 列出当前钱包中可以使用的所有资金 wormholed-cli whc_gettransaction "txid": 获取omni交易的解析 wormholed-cli whc_getbalance "address" propertyID: 获取指定地址指定资产的余额 wormholed-cli getproperty_MP propertyID: 列写omni系统中指定资产的基础信息 wormholed-cli listblocktransactions_MP height: 列出某个块高度含有的所有omni交易 wormholed-cli whc_listpendingtransactions: 列出当前节点的交易池中所有未确认的omni交易 wormholed-cli whc_getpayload "txid": 返回指定omni交易的载荷数据 wormholed-cli getsto_MP "txid" "*": 列出指定空投交易的所有参与者,以及金额信息 wormholed-cli getgrants_MP propertyID: 返回指定的管理资产的增发/销毁信息

01

【Spark on K8S】Spark里的k8s client

目前在我们的应用下,会有这样的一种特殊的场景。比如说 Driver 创建在 A 集群,但是需要 Driver 将 Executor Pod 创建到 B 集群去。所以我们这里会有两个集群的 master url,分别是集群 A 和集群 B。那么创建任务的模式就是 spark-subtit 的 master url 指向集群 A,然后给 Driver 的 k8s client 设置其创建 Executor Pod 的 master url 指向 B,那么在现有 Spark 的参数下,能否直接通过 SparkConf 或者环境变量来实现这一点呢?我们看看源码。 对于这样的需求,我们首先需要去了解 Spark 是如何跟 k8s 集群打交道的。Spark on K8S 在 submit 的时候默认是直接在 K8S Master 节点提交,通过 --master 或者 SparkConf 中的 spark.master 来指定。

02
领券