Searched defs:commit (Results 1 - 25 of 37) sorted by relevance

12

/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/util/
H A DTwoPhaseCommit.java24 * 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 DTwoPhaseCommitTool.java24 * 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 Dconnection.rb39 # 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 DCreateIndexTask.java98 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 DIndexCommit.java27 * <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 DSnapshotDeletionPolicy.java58 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 DTestTwoPhaseCommitTool.java49 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 DDIHWriter.java31 * 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 DSolrWriter.java101 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 DTestDocBuilder.java215 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 DTestMailEntityProcessor.java205 public void commit(boolean b) { method in class:TestMailEntityProcessor.SolrWriterImpl
/lucene-3.6.0/solr/core/src/java/org/apache/solr/core/
H A DSolrDeletionPolicy.java37 * 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 DTestTwoPhaseCommitTool.java49 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 DFacetTestUtils.java89 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 DTestSnapshotDeletionPolicy.java62 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 DTestSnapshotDeletionPolicy.java62 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 DSnapShooter.java176 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 DSolrServer.java60 * @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 DInstantiatedIndexWriter.java166 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 DRandomIndexWriter.java38 * 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 DRandomIndexWriter.java38 * 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 DDirectUpdateHandler.java239 public void commit(CommitUpdateCommand cmd) throws IOException { method in class:DirectUpdateHandler
H A DDirectUpdateHandler2.java51 * 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 DUpdateHandler.java137 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 DSimplePostTool.java79 "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"));

Completed in 35 milliseconds

12