本文整理汇总了Java中org.apache.solr.client.solrj.request.AbstractUpdateRequest类的典型用法代码示例。如果您正苦于以下问题：Java AbstractUpdateRequest类的具体用法？Java AbstractUpdateRequest怎么用？Java AbstractUpdateRequest使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
AbstractUpdateRequest类属于org.apache.solr.client.solrj.request包，在下文中一共展示了AbstractUpdateRequest类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testContentStreamRequest
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
@Test
public void testContentStreamRequest() throws Exception {
SolrServer server = getSolrServer();
server.deleteByQuery( "*:*" );// delete everything!
server.commit();
QueryResponse rsp = server.query( new SolrQuery( "*:*") );
Assert.assertEquals( 0, rsp.getResults().getNumFound() );
ContentStreamUpdateRequest up = new ContentStreamUpdateRequest("/update");
up.addFile(getFile("solrj/books.csv"), "application/csv");
up.setAction(AbstractUpdateRequest.ACTION.COMMIT, true, true);
NamedList<Object> result = server.request(up);
assertNotNull("Couldn't upload books.csv", result);
rsp = server.query( new SolrQuery( "*:*") );
Assert.assertEquals( 10, rsp.getResults().getNumFound() );
}
开发者ID:europeana，项目名称:search，代码行数:17，代码来源:SolrExampleTests.java
示例2: testMultiContentStreamRequest
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
@Test
public void testMultiContentStreamRequest() throws Exception {
SolrServer server = getSolrServer();
server.deleteByQuery( "*:*" );// delete everything!
server.commit();
QueryResponse rsp = server.query( new SolrQuery( "*:*") );
Assert.assertEquals( 0, rsp.getResults().getNumFound() );
ContentStreamUpdateRequest up = new ContentStreamUpdateRequest("/update");
up.addFile(getFile("solrj/docs1.xml"),"application/xml"); // 2
up.addFile(getFile("solrj/docs2.xml"),"application/xml"); // 3
up.setParam("a", "\u1234");
up.setParam(CommonParams.HEADER_ECHO_PARAMS, CommonParams.EchoParamStyle.ALL.toString());
up.setAction(AbstractUpdateRequest.ACTION.COMMIT, true, true);
NamedList<Object> result = server.request(up);
Assert.assertEquals("\u1234",
((NamedList)((NamedList) result.get("responseHeader")).get("params")).get("a"));
assertNotNull("Couldn't upload xml files", result);
rsp = server.query( new SolrQuery( "*:*") );
Assert.assertEquals( 5 , rsp.getResults().getNumFound() );
}
开发者ID:europeana，项目名称:search，代码行数:22，代码来源:SolrExampleTests.java
示例3: testNumberOfCommitsWithCommitAfterAdd
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
private void testNumberOfCommitsWithCommitAfterAdd()
throws SolrServerException, IOException {
log.info("### STARTING testNumberOfCommitsWithCommitAfterAdd");
long startCommits = getNumCommits((HttpSolrServer) clients.get(0));
ContentStreamUpdateRequest up = new ContentStreamUpdateRequest("/update");
up.addFile(getFile("books_numeric_ids.csv"), "application/csv");
up.setCommitWithin(900000);
up.setAction(AbstractUpdateRequest.ACTION.COMMIT, true, true);
NamedList<Object> result = clients.get(0).request(up);
long endCommits = getNumCommits((HttpSolrServer) clients.get(0));
assertEquals(startCommits + 1L, endCommits);
}
开发者ID:pkarmstr，项目名称:NYBC，代码行数:16，代码来源:BasicDistributedZkTest.java
示例4: indexAndCommitOneDocument
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
/**
* Indexiert das übergebene Dokument und übernimmt die Änderungen in den Solr-Index
* durch das Ausführen eines Commits.
*
* @param gutenbergDoc das zu indexierende Dokument
*/
public void indexAndCommitOneDocument(GutenbergDoc gutenbergDoc) {
SolrInputDocument document = buildSolrDoc(gutenbergDoc);
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.setBasicAuthCredentials(USERNAME, PASSWORD);
updateRequest.add(document);
updateRequest.setAction(AbstractUpdateRequest.ACTION.COMMIT, false, false);
try {
updateRequest.process(solrClient);
System.out.println("Dokument " + gutenbergDoc.getDocId() + " erfolgreich indexiert!");
}
catch (SolrServerException|IOException e) {
System.err.println("Fehler bei der Indexierung des Dokuments " + gutenbergDoc.getDocId() + ": " + e.getMessage());
updateRequest.rollback();
}
}
开发者ID:saschaszott，项目名称:suma-tech，代码行数:24，代码来源:SolrIndexer.java
示例5: indexDocumentsAndCommit
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
/**
* Indexiert die übergebene Liste von Dokumenten und führt am Ende ein Commit durch.
*
* Tritt während der Indexierung ein Fehler auf, so werden die Änderungen nicht
* zurückgenommen, die bereits erfolgreich in den Solr-Index geschrieben werden konnten.
*
* @param gutenbergDocs die Liste der zu indexierenden Dokumente
*/
public void indexDocumentsAndCommit(List<GutenbergDoc> gutenbergDocs) {
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.setBasicAuthCredentials(USERNAME, PASSWORD);
for (GutenbergDoc gutenbergDoc : gutenbergDocs) {
SolrInputDocument solrInputDocument = buildSolrDoc(gutenbergDoc);
if (gutenbergDoc.getDocId().equals("9")) {
// füge zu Dokument 9 ein Feld hinzu, dass es nicht im Solr-Schema gibt
solrInputDocument.addField("foo", "bar");
}
updateRequest.add(solrInputDocument);
}
updateRequest.setAction(AbstractUpdateRequest.ACTION.COMMIT, false, false);
try {
updateRequest.process(solrClient);
System.out.println(gutenbergDocs.size() + " Dokumente erfolgreich indexiert!");
}
catch (SolrServerException|IOException e) {
System.err.println("Fehler bei der Indexierung der Dokumente: " + e.getMessage());
updateRequest.rollback();
}
}
开发者ID:saschaszott，项目名称:suma-tech，代码行数:31，代码来源:SolrIndexer.java
示例6: indexAndCommitDocuments
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
/**
* Indexiert die übergebene Liste von Dokumenten und führt nach jedem Dokument einen Commit durch.
*
* Tritt während der Indexierung eines Dokuments ein Fehler auf, so gehen die zuvor bereits
* erfolgreich indexierten Dokumente nicht verloren.
*
* @param gutenbergDocs die Liste der zu indexierenden Dokumente
*/
public void indexAndCommitDocuments(List<GutenbergDoc> gutenbergDocs) {
for (GutenbergDoc gutenbergDoc : gutenbergDocs) {
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.setBasicAuthCredentials(USERNAME, PASSWORD);
SolrInputDocument solrInputDocument = buildSolrDoc(gutenbergDoc);
if (gutenbergDoc.getDocId().equals("9")) {
// füge zu Dokument 9 ein Feld hinzu, dass es nicht im Solr-Schema gibt
solrInputDocument.addField("foo", "bar");
}
updateRequest.add(solrInputDocument);
updateRequest.setAction(AbstractUpdateRequest.ACTION.COMMIT, false, false);
try {
updateRequest.process(solrClient);
System.out.println("Dokument " + gutenbergDoc.getDocId() + " erfolgreich indexiert!");
}
catch (SolrServerException|IOException e) {
System.err.println("Fehler bei der Indexierung der Dokumente: " + e.getMessage());
updateRequest.rollback();
}
}
}
开发者ID:saschaszott，项目名称:suma-tech，代码行数:32，代码来源:SolrIndexer.java
示例7: indexAndCommitOneDocument
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
/**
* Indexiert das übergebene Gutenberg-Dokument und übernimmt die Änderungen in den Solr-Index
* durch das Ausführen eines Commits.
*
* @param gutenbergDoc das zu indexierende Dokument
*/
private void indexAndCommitOneDocument(GutenbergDoc gutenbergDoc) {
SolrInputDocument document = buildSolrDoc(gutenbergDoc);
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.setBasicAuthCredentials(Configuration.USERNAME, Configuration.PASSWORD);
updateRequest.add(document);
updateRequest.setAction(AbstractUpdateRequest.ACTION.COMMIT, false, false);
try {
updateRequest.process(solrClient);
System.out.println("Dokument " + gutenbergDoc.getDocId() + " erfolgreich indexiert!");
}
catch (SolrServerException|IOException e) {
System.err.println("Fehler bei der Indexierung des Dokuments " + gutenbergDoc.getDocId() + ": " + e.getMessage());
updateRequest.rollback();
}
}
开发者ID:saschaszott，项目名称:suma-tech，代码行数:24，代码来源:SolrIndexerComplete.java
示例8: softCommit
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
static UpdateResponse softCommit(String url) throws SolrServerException, IOException {
HttpSolrServer server = null;
try {
server = new HttpSolrServer(url);
server.setConnectionTimeout(30000);
server.setSoTimeout(120000);
UpdateRequest ureq = new UpdateRequest();
ureq.setParams(new ModifiableSolrParams());
ureq.setAction(AbstractUpdateRequest.ACTION.COMMIT, false, true, true);
return ureq.process(server);
} finally {
if (server != null) {
server.shutdown();
}
}
}
开发者ID:yintaoxue，项目名称:read-open-source-code，代码行数:17，代码来源:OverseerCollectionProcessor.java
示例9: addDoc
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
@Override
public void addDoc(final SSDBNoSQLAddDocPar par) throws SSErr {
// according to Solr specification by adding a document with an ID already
// existing in the index will replace the document (eg. refer to
// http://stackoverflow.com/questions/8494923/solr-block-updating-of-existing-document or
// http://lucene.apache.org/solr/api-4_0_0-ALPHA/doc-files/tutorial.html )
try{
final ContentStreamUpdateRequest csur = new ContentStreamUpdateRequest("/update/extract");
final NamedList<Object> response;
csur.addContentStream(new ContentStreamBase.FileStream(new File(SSConf.getLocalWorkPath() + par.id)));
csur.setParam ("literal.id", par.id);
// csur.setParam ("stream.type", "application/octet-stream");
csur.setAction (AbstractUpdateRequest.ACTION.COMMIT, true, true);
response = solrServer.request(csur);
SSLogU.info("document w/ id " + par.id + " added successfully. ");
}catch(Exception error){
SSServErrReg.regErrThrow(error);
}
}
开发者ID:learning-layers，项目名称:SocialSemanticServer，代码行数:27，代码来源:SSDBNoSQLSolrImpl.java
示例10: optimizeIndex
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
/**
* Stößt die Optimierung des Solr-Index an.
*/
public void optimizeIndex() {
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.setBasicAuthCredentials(USERNAME, PASSWORD);
updateRequest.setAction(AbstractUpdateRequest.ACTION.OPTIMIZE, false, false);
try {
updateRequest.process(solrClient);
System.out.println("Index erfolgreich optimiert!");
} catch (SolrServerException|IOException e) {
System.err.println("Fehler beim Index-Optimize: " + e.getMessage());
}
}
开发者ID:saschaszott，项目名称:suma-tech，代码行数:15，代码来源:SolrIndexer.java
示例11: deleteDocById
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
/**
* Löscht das Dokument mit der übergebene ID aus dem Solr-Index.
*
* @param id die ID des zu löschenden Dokuments
*/
public void deleteDocById(String id) {
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.setBasicAuthCredentials(USERNAME, PASSWORD);
updateRequest.deleteById(id);
updateRequest.setAction(AbstractUpdateRequest.ACTION.COMMIT, false, false);
try {
updateRequest.process(solrClient);
System.out.println("Dokument mit ID " + id + " erfolgreich gelöscht!");
} catch (SolrServerException|IOException e) {
System.err.println("Fehler beim Löschen des Dokuments " + id + ": " + e.getMessage());
}
}
开发者ID:saschaszott，项目名称:suma-tech，代码行数:18，代码来源:SolrIndexer.java
示例12: deleteAllDocs
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
/**
* Entfernt alle Dokumente aus dem Solr-Index.
*/
public void deleteAllDocs() {
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.setBasicAuthCredentials(USERNAME, PASSWORD);
updateRequest.deleteByQuery("*:*");
updateRequest.setAction(AbstractUpdateRequest.ACTION.COMMIT, false, false);
try {
updateRequest.process(solrClient);
System.out.println("Alle Dokumente erfolgreich gelöscht!");
} catch (SolrServerException|IOException e) {
System.err.println("Fehler beim Löschen aller Dokumente: " + e.getMessage());
}
}
开发者ID:saschaszott，项目名称:suma-tech，代码行数:16，代码来源:SolrIndexer.java
示例13: deleteDocsByNumOfDownloads
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
/**
* Löscht alle Dokumente, die nicht mehr als maxNumOfDownloads viele Downloads in den letzten 30 Tagen hatten
*
* @param maxNumOfDownloads Schwellwert
*/
private void deleteDocsByNumOfDownloads(int maxNumOfDownloads) {
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.setBasicAuthCredentials(Configuration.USERNAME, Configuration.PASSWORD);
// TODO geeignete Delete Query hinzufügen
updateRequest.setAction(AbstractUpdateRequest.ACTION.COMMIT, false, false);
try {
updateRequest.process(solrClient);
System.out.println("Dokumente erfolgreich gelöscht!");
} catch (SolrServerException|IOException e) {
System.err.println("Fehler beim Löschen: " + e.getMessage());
}
}
开发者ID:saschaszott，项目名称:suma-tech，代码行数:20，代码来源:SolrIndexerComplete.java
示例14: getQueryResponse
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
private QueryResponse getQueryResponse(AbstractUpdateRequest request)
throws org.apache.solr.client.solrj.SolrServerException, IOException {
UpdateResponse response = request.process(solrClient);
Assert.assertEquals(0, response.getStatus());
solrClient.commit();
// verify number of results
SolrQuery query = new SolrQuery("*:*");
QueryResponse qResponse = solrClient.query(query);
return qResponse;
}
开发者ID:bbende，项目名称:solrj-custom-json-update，代码行数:13，代码来源:IndexJSONSchemalessTest.java
示例15: commitOnLeader
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
private void commitOnLeader(String leaderUrl) throws SolrServerException,
IOException {
HttpSolrServer server = new HttpSolrServer(leaderUrl);
try {
server.setConnectionTimeout(30000);
UpdateRequest ureq = new UpdateRequest();
ureq.setParams(new ModifiableSolrParams());
ureq.getParams().set(DistributedUpdateProcessor.COMMIT_END_POINT, true);
ureq.getParams().set(UpdateParams.OPEN_SEARCHER, false);
ureq.setAction(AbstractUpdateRequest.ACTION.COMMIT, false, true).process(
server);
} finally {
server.shutdown();
}
}
开发者ID:europeana，项目名称:search，代码行数:16，代码来源:RecoveryStrategy.java
示例16: commitOnLeader
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
private void commitOnLeader(String leaderUrl) throws SolrServerException, IOException {
HttpSolrServer server = new HttpSolrServer(leaderUrl);
server.setConnectionTimeout(30000);
server.setSoTimeout(60000);
UpdateRequest ureq = new UpdateRequest();
ureq.setParams(new ModifiableSolrParams());
ureq.getParams().set(DistributedUpdateProcessor.COMMIT_END_POINT, true);
ureq.getParams().set(UpdateParams.OPEN_SEARCHER, false);
ureq.setAction(AbstractUpdateRequest.ACTION.COMMIT, false, true).process(
server);
server.shutdown();
}
开发者ID:pkarmstr，项目名称:NYBC，代码行数:13，代码来源:RecoveryStrategy.java
示例17: add
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
@Override
public void add(String path, Map<String, Object> data, ResourceBinary binary) throws IndexException {
if (binary == null) {
add(path, data);
return;
}
ContentStreamUpdateRequest request = new ContentStreamUpdateRequest("/update/extract");
request.addContentStream(new AssetContentStream(binary));
request.setParam("literal.id", buildId(path));
Set<String> fields = data.keySet();
for (String field : fields) {
if (field.equals(this.idField)) {
throw new IndexException("ID field must not get populated through data fields.");
}
Object fieldValue = data.get(field);
if (fieldValue != null) {
if (fieldValue instanceof Collection) {
Collection<?> fieldValues = (Collection) fieldValue;
for (Object value : fieldValues) {
// TODO deal with numeric & date type values (format to string)
request.setParam("literal." + field, valueToString(value));
}
} else {
// assume it's one of the supported data types
request.setParam("literal." + field, valueToString(fieldValue));
}
}
}
request.setAction(AbstractUpdateRequest.ACTION.COMMIT, true, true);
try {
solrServer.request(request);
} catch (Exception e) {
throw new IndexException(e);
}
}
开发者ID:mwmd，项目名称:ease，代码行数:38，代码来源:SolrIndexServer.java
示例18: setupCores
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
private UpdateRequest setupCores() throws SolrServerException, IOException {
UpdateRequest up = new UpdateRequest();
up.setAction(AbstractUpdateRequest.ACTION.COMMIT, true, true);
up.deleteByQuery("*:*");
up.process(getSolrCore0());
up.process(getSolrCore1());
up.clear();
// Add something to each core
SolrInputDocument doc = new SolrInputDocument();
doc.setField("id", "AAA");
doc.setField("name", "core0");
// Add to core0
up.add(doc);
up.process(getSolrCore0());
// Add to core1
doc.setField("id", "BBB");
doc.setField("name", "core1");
up.add(doc);
up.process(getSolrCore1());
// Now Make sure AAA is in 0 and BBB in 1
SolrQuery q = new SolrQuery();
QueryRequest r = new QueryRequest(q);
q.setQuery("id:AAA");
assertEquals(1, r.process(getSolrCore0()).getResults().size());
assertEquals(0, r.process(getSolrCore1()).getResults().size());
assertEquals(1,
getSolrCore0().query(new SolrQuery("id:AAA")).getResults().size());
assertEquals(0,
getSolrCore0().query(new SolrQuery("id:BBB")).getResults().size());
assertEquals(0,
getSolrCore1().query(new SolrQuery("id:AAA")).getResults().size());
assertEquals(1,
getSolrCore1().query(new SolrQuery("id:BBB")).getResults().size());
return up;
}
开发者ID:europeana，项目名称:search，代码行数:43，代码来源:MergeIndexesExampleTestBase.java
示例19: addCommit
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
void addCommit(UpdateRequest ureq, CommitUpdateCommand cmd) {
if (cmd == null) return;
ureq.setAction(cmd.optimize ? AbstractUpdateRequest.ACTION.OPTIMIZE
: AbstractUpdateRequest.ACTION.COMMIT, false, cmd.waitSearcher, cmd.maxOptimizeSegments, cmd.softCommit, cmd.expungeDeletes, cmd.openSearcher);
}
开发者ID:europeana，项目名称:search，代码行数:6，代码来源:SolrCmdDistributor.java
示例20: addCommit
import org.apache.solr.client.solrj.request.AbstractUpdateRequest; //导入依赖的package包/类
void addCommit(UpdateRequestExt ureq, CommitUpdateCommand cmd) {
if (cmd == null) return;
ureq.setAction(cmd.optimize ? AbstractUpdateRequest.ACTION.OPTIMIZE
: AbstractUpdateRequest.ACTION.COMMIT, false, cmd.waitSearcher, cmd.maxOptimizeSegments, cmd.softCommit, cmd.expungeDeletes);
}
开发者ID:pkarmstr，项目名称:NYBC，代码行数:6，代码来源:SolrCmdDistributor.java
注：本文中的org.apache.solr.client.solrj.request.AbstractUpdateRequest类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论