[hibernate-commits] Hibernate SVN: r12868 - in trunk/HibernateExt/search/src: java/org/hibernate/search/store and 1 other directories.

hibernate-commits at lists.jboss.org hibernate-commits at lists.jboss.org
Tue Jul 31 13:41:01 EDT 2007


Author: epbernard
Date: 2007-07-31 13:41:01 -0400 (Tue, 31 Jul 2007)
New Revision: 12868

Modified:
   trunk/HibernateExt/search/src/java/org/hibernate/search/backend/LuceneIndexingParameters.java
   trunk/HibernateExt/search/src/java/org/hibernate/search/backend/Workspace.java
   trunk/HibernateExt/search/src/java/org/hibernate/search/store/DirectoryProviderFactory.java
   trunk/HibernateExt/search/src/test/org/hibernate/search/test/SearchTestCase.java
Log:
HSEARCH-67 class lucene indexing prperties by transaction and batch

Modified: trunk/HibernateExt/search/src/java/org/hibernate/search/backend/LuceneIndexingParameters.java
===================================================================
--- trunk/HibernateExt/search/src/java/org/hibernate/search/backend/LuceneIndexingParameters.java	2007-07-31 16:55:45 UTC (rev 12867)
+++ trunk/HibernateExt/search/src/java/org/hibernate/search/backend/LuceneIndexingParameters.java	2007-07-31 17:41:01 UTC (rev 12868)
@@ -12,11 +12,11 @@
  */
 public class LuceneIndexingParameters {
 	
-	private int mergeFactor = 10;
+	private int transactionMergeFactor = 10;
 	
-	private int maxMergeDocs = Integer.MAX_VALUE;
+	private int transactionMaxMergeDocs = Integer.MAX_VALUE;
 	
-	private int maxBufferedDocs = 10;
+	private int transactionMaxBufferedDocs = 10;
 	
 	private int batchMergeFactor = 10;
 	
@@ -35,28 +35,28 @@
 	 * Constructor which instantiates a new parameter object with the the default values.
 	 */
 	public LuceneIndexingParameters() {
-		mergeFactor = DEFAULT_MERGE_FACTOR;
+		transactionMergeFactor = DEFAULT_MERGE_FACTOR;
 		batchMergeFactor = DEFAULT_MERGE_FACTOR;
-		maxMergeDocs = DEFAULT_MAX_MERGE_DOCS;
+		transactionMaxMergeDocs = DEFAULT_MAX_MERGE_DOCS;
 		batchMaxMergeDocs = DEFAULT_MAX_MERGE_DOCS;
-		maxBufferedDocs = DEFAULT_MAX_BUFFERED_DOCS;
+		transactionMaxBufferedDocs = DEFAULT_MAX_BUFFERED_DOCS;
 		batchMaxBufferedDocs = DEFAULT_MAX_BUFFERED_DOCS;
 	}
 	
-	public int getMaxMergeDocs() {
-		return maxMergeDocs;
+	public int getTransactionMaxMergeDocs() {
+		return transactionMaxMergeDocs;
 	}
 
-	public void setMaxMergeDocs(int maxMergeDocs) {
-		this.maxMergeDocs = maxMergeDocs;
+	public void setTransactionMaxMergeDocs(int transactionMaxMergeDocs) {
+		this.transactionMaxMergeDocs = transactionMaxMergeDocs;
 	}
 
-	public int getMergeFactor() {
-		return mergeFactor;
+	public int getTransactionMergeFactor() {
+		return transactionMergeFactor;
 	}
 
-	public void setMergeFactor(int mergeFactor) {
-		this.mergeFactor = mergeFactor;
+	public void setTransactionMergeFactor(int transactionMergeFactor) {
+		this.transactionMergeFactor = transactionMergeFactor;
 	}
 
 	public int getBatchMaxMergeDocs() {
@@ -83,11 +83,11 @@
 		this.batchMaxBufferedDocs = batchMaxBufferedDocs;
 	}
 
-	public int getMaxBufferedDocs() {
-		return maxBufferedDocs;
+	public int getTransactionMaxBufferedDocs() {
+		return transactionMaxBufferedDocs;
 	}
 
-	public void setMaxBufferedDocs(int maxBufferedDocs) {
-		this.maxBufferedDocs = maxBufferedDocs;
+	public void setTransactionMaxBufferedDocs(int transactionMaxBufferedDocs) {
+		this.transactionMaxBufferedDocs = transactionMaxBufferedDocs;
 	}
 }

Modified: trunk/HibernateExt/search/src/java/org/hibernate/search/backend/Workspace.java
===================================================================
--- trunk/HibernateExt/search/src/java/org/hibernate/search/backend/Workspace.java	2007-07-31 16:55:45 UTC (rev 12867)
+++ trunk/HibernateExt/search/src/java/org/hibernate/search/backend/Workspace.java	2007-07-31 17:41:01 UTC (rev 12868)
@@ -124,9 +124,9 @@
 				writer.setMaxBufferedDocs( indexingParams.getBatchMaxBufferedDocs() );
 			}
 			else {
-				writer.setMergeFactor( indexingParams.getMergeFactor() );
-				writer.setMaxMergeDocs( indexingParams.getMaxMergeDocs() );
-				writer.setMaxBufferedDocs( indexingParams.getMaxBufferedDocs() );
+				writer.setMergeFactor( indexingParams.getTransactionMergeFactor() );
+				writer.setMaxMergeDocs( indexingParams.getTransactionMaxMergeDocs() );
+				writer.setMaxBufferedDocs( indexingParams.getTransactionMaxBufferedDocs() );
 			}
 
 			writers.put( provider, writer );

Modified: trunk/HibernateExt/search/src/java/org/hibernate/search/store/DirectoryProviderFactory.java
===================================================================
--- trunk/HibernateExt/search/src/java/org/hibernate/search/store/DirectoryProviderFactory.java	2007-07-31 16:55:45 UTC (rev 12867)
+++ trunk/HibernateExt/search/src/java/org/hibernate/search/store/DirectoryProviderFactory.java	2007-07-31 17:41:01 UTC (rev 12868)
@@ -53,9 +53,8 @@
 	private static final String MERGE_FACTOR = "merge_factor";
 	private static final String MAX_MERGE_DOCS = "max_merge_docs";
 	private static final String MAX_BUFFERED_DOCS = "max_buffered_docs";
-	private static final String BATCH_MERGE_FACTOR = "merge_factor.batch";
-	private static final String BATCH_MAX_MERGE_DOCS = "max_merge_docs.batch";
-	private static final String BATCH_MAX_BUFFERED_DOCS = "max_buffered_docs.batch";
+	private static final String BATCH = "batch.";
+	private static final String TRANSACTION = "transaction.";
 
 	private static final String SHARDING_STRATEGY = "sharding_strategy";
 	private static final String NBR_OF_SHARDS = SHARDING_STRATEGY + ".nbr_of_shards";
@@ -189,61 +188,61 @@
 	private void configureIndexingParameters(SearchFactoryImplementor searchFactoryImplementor, Properties indexProps, DirectoryProvider<?> provider) {
 		
 		LuceneIndexingParameters indexingParams = new LuceneIndexingParameters();
-		String s = indexProps.getProperty(MERGE_FACTOR);
+		String s = indexProps.getProperty(TRANSACTION + MERGE_FACTOR);
 		
 		if (!StringHelper.isEmpty( s )) {
 			try{
-				indexingParams.setMergeFactor(Integer.valueOf(s));
+				indexingParams.setTransactionMergeFactor(Integer.valueOf(s));
 				indexingParams.setBatchMergeFactor(Integer.valueOf(s));
 			} catch (NumberFormatException ne) {
-				throw new HibernateException("Invalid value for " + MERGE_FACTOR + ": " + s);
+				throw new SearchException("Invalid value for " + TRANSACTION + MERGE_FACTOR + ": " + s);
 			}
 		}
 
-		s = indexProps.getProperty(MAX_MERGE_DOCS);
+		s = indexProps.getProperty(TRANSACTION + MAX_MERGE_DOCS);
 		if (!StringHelper.isEmpty( s )) {
 			try{
-				indexingParams.setMaxMergeDocs(Integer.valueOf(s));
+				indexingParams.setTransactionMaxMergeDocs(Integer.valueOf(s));
 				indexingParams.setBatchMaxMergeDocs(Integer.valueOf(s));
 			} catch (NumberFormatException ne) {
-				throw new HibernateException("Invalid value for " + MAX_MERGE_DOCS + ": " + s);
+				throw new SearchException("Invalid value for " + TRANSACTION + MAX_MERGE_DOCS + ": " + s);
 			}
 		}
 		
-		s = indexProps.getProperty(MAX_BUFFERED_DOCS);
+		s = indexProps.getProperty(TRANSACTION + MAX_BUFFERED_DOCS);
 		if (!StringHelper.isEmpty( s )) {
 			try{
-				indexingParams.setMaxBufferedDocs(Integer.valueOf(s));
+				indexingParams.setTransactionMaxBufferedDocs(Integer.valueOf(s));
 				indexingParams.setBatchMaxBufferedDocs(Integer.valueOf(s));
 			} catch (NumberFormatException ne) {
-				throw new HibernateException("Invalid value for " + MAX_BUFFERED_DOCS + ": " + s);
+				throw new SearchException("Invalid value for " + TRANSACTION + MAX_BUFFERED_DOCS + ": " + s);
 			}
 		}		
 				
-		s = indexProps.getProperty(BATCH_MERGE_FACTOR);
+		s = indexProps.getProperty(BATCH + MERGE_FACTOR);
 		if (!StringHelper.isEmpty( s )) {
 			try{
 				indexingParams.setBatchMergeFactor(Integer.valueOf(s));
 			} catch (NumberFormatException ne) {
-				throw new HibernateException("Invalid value for " + BATCH_MERGE_FACTOR + ": " + s);
+				throw new SearchException("Invalid value for " + BATCH + MERGE_FACTOR + ": " + s);
 			}
 		}
 		
-		s = indexProps.getProperty(BATCH_MAX_MERGE_DOCS);
+		s = indexProps.getProperty(BATCH + MAX_MERGE_DOCS);
 		if (!StringHelper.isEmpty( s )) {
 			try{
 				indexingParams.setBatchMaxMergeDocs(Integer.valueOf(s));
 			} catch (NumberFormatException ne) {
-				throw new HibernateException("Invalid value for " + BATCH_MAX_MERGE_DOCS + ": " + s);
+				throw new SearchException("Invalid value for " + BATCH + MAX_MERGE_DOCS + ": " + s);
 			}
 		}
 		
-		s = indexProps.getProperty(BATCH_MAX_BUFFERED_DOCS);
+		s = indexProps.getProperty(BATCH + MAX_BUFFERED_DOCS);
 		if (!StringHelper.isEmpty( s )) {
 			try{
 				indexingParams.setBatchMaxBufferedDocs(Integer.valueOf(s));
 			} catch (NumberFormatException ne) {
-				throw new HibernateException("Invalid value for " + BATCH_MAX_BUFFERED_DOCS + ": " + s);
+				throw new SearchException("Invalid value for " + BATCH + MAX_BUFFERED_DOCS + ": " + s);
 			}
 		}	
 		searchFactoryImplementor.addIndexingParmeters(provider, indexingParams);

Modified: trunk/HibernateExt/search/src/test/org/hibernate/search/test/SearchTestCase.java
===================================================================
--- trunk/HibernateExt/search/src/test/org/hibernate/search/test/SearchTestCase.java	2007-07-31 16:55:45 UTC (rev 12867)
+++ trunk/HibernateExt/search/src/test/org/hibernate/search/test/SearchTestCase.java	2007-07-31 17:41:01 UTC (rev 12868)
@@ -40,7 +40,7 @@
 	protected void configure(org.hibernate.cfg.Configuration cfg) {
 		cfg.setProperty( "hibernate.search.default.directory_provider", RAMDirectoryProvider.class.getName() );
 		cfg.setProperty( Environment.ANALYZER_CLASS, StopAnalyzer.class.getName() );
-		cfg.setProperty( "hibernate.search.default.merge_factor", "100" );
-		cfg.setProperty( "hibernate.search.default.max_buffered_docs", "1000" );
+		cfg.setProperty( "hibernate.search.default.transaction.merge_factor", "100" );
+		cfg.setProperty( "hibernate.search.default.batch.max_buffered_docs", "1000" );
 	}
 }




More information about the hibernate-commits mailing list