/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/util/ |
H A D | TwoPhaseCommit.java | 24 * An interface for implementations that support 2-phase commit. You can use 25 * {@link TwoPhaseCommitTool} to execute a 2-phase commit algorithm over several 33 * The first stage of a 2-phase commit. Implementations should do as much work 35 * 2-phase commit fails, {@link #rollback()} is called to discard all changes 36 * since last successful commit. 41 * Like {@link #commit()}, but takes an additional commit data to be included 42 * w/ the commit. 45 * included w/ the commit and may discard it altogether. Consult the actual 53 * The second phase of a 2-phase commit 58 public void commit() throws IOException; method in interface:TwoPhaseCommit 67 public void commit(Map<String, String> commitData) throws IOException; method in interface:TwoPhaseCommit [all...] |
H A D | TwoPhaseCommitTool.java | 24 * A utility for executing 2-phase commit on several objects. 35 * like to store commitData as part of the commit. 55 public void commit() throws IOException { method in class:TwoPhaseCommitTool.TwoPhaseCommitWrapper 56 commit(commitData); 59 public void commit(Map<String, String> commitData) throws IOException { method in class:TwoPhaseCommitTool.TwoPhaseCommitWrapper 60 tpc.commit(this.commitData); 83 * object fails to commit(). 88 super("commit() failed on " + obj); 108 * Executes a 2-phase commit algorithm by first 110 * it proceeds with {@link TwoPhaseCommit#commit()} [all...] |
/lucene-3.6.0/solr/client/ruby/solr-ruby/lib/solr/ |
H A D | connection.rb | 39 # does not autocommit. Maybe #send should check for the request types that require a commit and 40 # commit in #send instead of the individual methods? 62 commit if @autocommit 108 # sends a commit message to the server 109 def commit(options={}) method in class:Solr 133 commit if @autocommit 140 commit if @autocommit 156 # to some requests: add(), query(), commit(), delete() or send()
|
/lucene-3.6.0/lucene/contrib/benchmark/src/java/org/apache/lucene/benchmark/byTask/tasks/ |
H A D | CreateIndexTask.java | 98 public static IndexWriterConfig createWriterConfig(Config config, PerfRunData runData, OpenMode mode, IndexCommit commit) { argument 104 if(commit != null) 105 iwConf.setIndexCommit(commit); 165 public static IndexWriter configureWriter(Config config, PerfRunData runData, OpenMode mode, IndexCommit commit) throws CorruptIndexException, LockObtainFailedException, IOException { argument 166 IndexWriter writer = new IndexWriter(runData.getDirectory(), createWriterConfig(config, runData, mode, commit));
|
/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/index/ |
H A D | IndexCommit.java | 27 * <p>Expert: represents a single commit into an index as seen by the 35 * is completed, is an index commit.</p> 37 * <p>Each index commit point has a unique segments file 39 * later index commit point would have a larger N.</p> 48 * with this commit point. 53 * Returns all index files referenced by this commit point. 63 * Delete this commit point. This only applies when using 64 * the commit point in the context of IndexWriter's 67 * Upon calling this, the writer is notified that this commit 70 * Decision that a commit 126 compareTo(IndexCommit commit) argument [all...] |
H A D | SnapshotDeletionPolicy.java | 58 IndexCommit commit; field in class:SnapshotDeletionPolicy.SnapshotInfo 60 public SnapshotInfo(String id, String segmentsFileName, IndexCommit commit) { argument 63 this.commit = commit; 95 // Suppress the delete request if this commit point is 147 // multiple IDs could point to the same commit point (segments file name) 196 protected void registerSnapshotInfo(String id, String segment, IndexCommit commit) { argument 197 idToSnapshot.put(id, new SnapshotInfo(id, segment, commit)); 216 * open an IndexReader on a specific commit point, or rollback the index by 221 * a unique identifier of the commit tha [all...] |
/lucene-3.6.0/lucene/core/src/test/org/apache/lucene/util/ |
H A D | TestTwoPhaseCommitTool.java | 49 assertFalse("commit should not have been called before all prepareCommit were", commitCalled); 55 public void commit() throws IOException { method in class:TestTwoPhaseCommitTool.TwoPhaseCommitImpl 56 commit(null); 59 public void commit(Map<String, String> commitData) throws IOException { method in class:TestTwoPhaseCommitTool.TwoPhaseCommitImpl 82 // tests that prepareCommit() is called on all objects before commit() 88 // following call will fail if commit() is called before all prepare() were 98 // we should not hit failures on commit usually 114 assertTrue("rollback was not called while a failure occurred during the 2-phase commit", tpc.rollbackCalled); 120 // tests that TwoPhaseCommitWrapper delegates prepare/commit w/ commitData 132 wrapper.commit(); [all...] |
/lucene-3.6.0/solr/contrib/dataimporthandler/src/java/org/apache/solr/handler/dataimport/ |
H A D | DIHWriter.java | 31 * If this writer supports transactions or commit points, then commit any changes, 36 public void commit(boolean optimize); method in interface:DIHWriter 47 * If this writer supports transactions or commit points, then roll back any uncommitted changes.
|
H A D | SolrWriter.java | 101 public void commit(boolean optimize) { method in class:SolrWriter 103 CommitUpdateCommand commit = new CommitUpdateCommand(optimize); 104 processor.processCommit(commit); 106 log.error("Exception while solr commit.", t);
|
/lucene-3.6.0/solr/contrib/dataimporthandler/src/test/org/apache/solr/handler/dataimport/ |
H A D | TestDocBuilder.java | 215 public void commit(boolean b) { method in class:TestDocBuilder.SolrWriterImpl
|
/lucene-3.6.0/solr/contrib/dataimporthandler-extras/src/test/org/apache/solr/handler/dataimport/ |
H A D | TestMailEntityProcessor.java | 205 public void commit(boolean b) { method in class:TestMailEntityProcessor.SolrWriterImpl
|
/lucene-3.6.0/solr/core/src/java/org/apache/solr/core/ |
H A D | SolrDeletionPolicy.java | 37 * Standard Solr deletion policy that allows reserving index commit points 75 static String str(IndexCommit commit) { argument 78 sb.append("commit{"); 80 Directory dir = commit.getDirectory(); 89 sb.append(",segFN=").append(commit.getSegmentsFileName()); 90 sb.append(",version=").append(commit.getVersion()); 91 sb.append(",generation=").append(commit.getGeneration()); 92 sb.append(",filenames=").append(commit.getFileNames()); 103 for (IndexCommit commit : (List<IndexCommit>) commits) { 105 sb.append(str(commit)); 178 getId(IndexCommit commit) argument [all...] |
/lucene-3.6.0/lucene/backwards/src/test/org/apache/lucene/util/ |
H A D | TestTwoPhaseCommitTool.java | 49 assertFalse("commit should not have been called before all prepareCommit were", commitCalled); 55 public void commit() throws IOException { method in class:TestTwoPhaseCommitTool.TwoPhaseCommitImpl 56 commit(null); 59 public void commit(Map<String, String> commitData) throws IOException { method in class:TestTwoPhaseCommitTool.TwoPhaseCommitImpl 82 // tests that prepareCommit() is called on all objects before commit() 88 // following call will fail if commit() is called before all prepare() were 98 // we should not hit failures on commit usually 114 assertTrue("rollback was not called while a failure occurred during the 2-phase commit", tpc.rollbackCalled); 120 // tests that TwoPhaseCommitWrapper delegates prepare/commit w/ commitData 132 wrapper.commit(); [all...] |
/lucene-3.6.0/lucene/contrib/facet/src/test/org/apache/lucene/facet/ |
H A D | FacetTestUtils.java | 89 pair.indexWriter.commit(); 90 pair.taxWriter.commit(); 160 public void commit() throws IOException { method in class:FacetTestUtils.IndexTaxonomyWriterPair 161 indexWriter.commit(); 162 taxWriter.commit();
|
/lucene-3.6.0/lucene/core/src/test/org/apache/lucene/index/ |
H A D | TestSnapshotDeletionPolicy.java | 62 protected void checkMaxDoc(IndexCommit commit, int expectedMaxDoc) throws Exception { argument 63 IndexReader reader = IndexReader.open(commit, true); 75 // create dummy document to trigger commit. 77 writer.commit(); 113 writer.commit(); 130 writer.commit(); 156 // Add one more document to force writer to commit a 279 writer.commit(); 297 // Do one last commit, so that after we release all snapshots, we stay w/ one commit [all...] |
/lucene-3.6.0/lucene/backwards/src/test/org/apache/lucene/index/ |
H A D | TestSnapshotDeletionPolicy.java | 62 protected void checkMaxDoc(IndexCommit commit, int expectedMaxDoc) throws Exception { argument 63 IndexReader reader = IndexReader.open(commit, true); 75 // create dummy document to trigger commit. 77 writer.commit(); 113 writer.commit(); 130 writer.commit(); 156 // Add one more document to force writer to commit a 279 writer.commit(); 297 // Do one last commit, so that after we release all snapshots, we stay w/ one commit [all...] |
/lucene-3.6.0/solr/core/src/java/org/apache/solr/handler/ |
H A D | SnapShooter.java | 176 public FileCopier(IndexDeletionPolicyWrapper delPolicy, IndexCommit commit) { argument 178 this.indexCommit = commit;
|
/lucene-3.6.0/solr/solrj/src/java/org/apache/solr/client/solrj/ |
H A D | SolrServer.java | 60 * @param commitWithinMs max time (in ms) before a commit will happen 85 * @param commitWithinMs max time (in ms) before a commit will happen 112 * @param commitWithinMs max time (in ms) before a commit will happen 137 * @param commitWithinMs max time (in ms) before a commit will happen 147 * Performs an explicit commit, causing pending documents to be committed for indexing 153 public UpdateResponse commit( ) throws SolrServerException, IOException { method in class:SolrServer 154 return commit(true, true); 171 * Performs an explicit commit, causing pending documents to be committed for indexing 177 public UpdateResponse commit( boolean waitFlush, boolean waitSearcher ) throws SolrServerException, IOException { method in class:SolrServer 213 * a commit et [all...] |
/lucene-3.6.0/lucene/contrib/instantiated/src/java/org/apache/lucene/store/instantiated/ |
H A D | InstantiatedIndexWriter.java | 166 commit(); 180 public void commit() throws IOException { method in class:InstantiatedIndexWriter 467 * Try to do all calculations in this method rather than in commit, as this is a non locking method. 565 tokens.add(token); // the vector will be built on commit. 647 // if too many documents in buffer, commit. 649 commit(/*lock*/);
|
/lucene-3.6.0/lucene/test-framework/src/java/org/apache/lucene/index/ |
H A D | RandomIndexWriter.java | 38 * commit periodically; may or may not forceMerge in the end, 109 // getReader, commit, etc. are called, we do an 131 System.out.println("RIW.add/updateDocument: now doing a commit at docCount=" + docCount); 133 w.commit(); 171 public void commit() throws CorruptIndexException, IOException { method in class:RandomIndexWriter 172 w.commit(); 235 w.commit(); 242 w.commit();
|
/lucene-3.6.0/lucene/backwards/src/test-framework/java/org/apache/lucene/index/ |
H A D | RandomIndexWriter.java | 38 * commit periodically; may or may not forceMerge in the end, 105 // getReader, commit, etc. are called, we do an 127 System.out.println("RIW.add/updateDocument: now doing a commit at docCount=" + docCount); 129 w.commit(); 167 public void commit() throws CorruptIndexException, IOException { method in class:RandomIndexWriter 168 w.commit(); 231 w.commit(); 238 w.commit();
|
/lucene-3.6.0/solr/core/src/java/org/apache/solr/update/ |
H A D | DirectUpdateHandler.java | 239 public void commit(CommitUpdateCommand cmd) throws IOException { method in class:DirectUpdateHandler
|
H A D | DirectUpdateHandler2.java | 51 * This version supports efficient removal of duplicates on a commit. It works by maintaining 52 * a related count for every document being added or deleted. At commit time, for every id with a count, 109 <p>* deleteByQuery causes a commit to happen (close current index writer, open new index reader) 136 // tracks when auto-commit should occur 150 // Pass fairness=true so commit request is not starved 384 public void commit(CommitUpdateCommand cmd) throws IOException { method in class:DirectUpdateHandler2 419 // and adds of another commit being done. 422 // reset commit tracking 467 // reset commit tracking
|
H A D | UpdateHandler.java | 137 public abstract void commit(CommitUpdateCommand cmd) throws IOException; method in class:UpdateHandler
|
/lucene-3.6.0/solr/core/src/java/org/apache/solr/util/ |
H A D | SimplePostTool.java | 79 "URL to POST to, the Content-Type of the data, whether a commit\n"+ 132 if ("yes".equals(System.getProperty("commit",DEFAULT_COMMIT))) { 134 t.commit(); 194 * Does a simple commit operation 196 public void commit() { method in class:SimplePostTool 197 doGet(appendParam(solrUrl.toString(), "commit=true"));
|