diff src/luan/modules/lucene/LuceneIndex.java @ 1333:25746915a241

merge Luan and LuanState
author Franklin Schmidt <fschmidt@gmail.com>
date Tue, 12 Feb 2019 22:33:40 -0700
parents 48f302bdc187
children e0cf0d108a77
line wrap: on
line diff
--- a/src/luan/modules/lucene/LuceneIndex.java	Tue Feb 12 21:50:26 2019 -0700
+++ b/src/luan/modules/lucene/LuceneIndex.java	Tue Feb 12 22:33:40 2019 -0700
@@ -69,7 +69,6 @@
 import luan.lib.parser.ParseException;
 import luan.modules.Utils;
 import luan.Luan;
-import luan.LuanState;
 import luan.LuanTable;
 import luan.LuanFunction;
 import luan.LuanCloner;
@@ -103,10 +102,10 @@
 	private int writeCount;
 
 	private final ConcurrentMap<String,Map<String,LuanFunction>> indexedOnlyFields = new ConcurrentHashMap<String,Map<String,LuanFunction>>();
-	private final LuanState luanMine = new LuanState();
+	private final Luan luanMine = new Luan();
 	private final LuanCloner cloner = new LuanCloner(LuanCloner.Type.COMPLETE);
 
-	public LuceneIndex(LuanState luan,String indexDirStr,FieldParser defaultFieldParser,String[] defaultFields)
+	public LuceneIndex(Luan luan,String indexDirStr,FieldParser defaultFieldParser,String[] defaultFields)
 		throws LuanException, IOException
 	{
 		mfp = defaultFieldParser==null ? new MultiFieldParser() : new MultiFieldParser(defaultFieldParser,defaultFields);
@@ -167,7 +166,7 @@
 		return new Term(key,br);
 	}
 
-	public void delete(LuanState luan,String queryStr) throws LuanException, IOException, ParseException {
+	public void delete(Luan luan,String queryStr) throws LuanException, IOException, ParseException {
 		Query query = SaneQueryParser.parseQuery(mfp,queryStr);
 
 		boolean commit = !writeLock.isHeldByCurrentThread();
@@ -188,7 +187,7 @@
 		map.put(field,fn);
 	}
 
-	public void save(LuanState luan,LuanTable doc) throws LuanException, IOException {
+	public void save(Luan luan,LuanTable doc) throws LuanException, IOException {
 		Set indexedOnlySet = new HashSet();
 		Object typeObj = doc.get("type");
 		if( typeObj==null )
@@ -231,7 +230,7 @@
 		}
 	}
 
-	public void update_in_transaction(LuanState luan,LuanFunction fn) throws IOException, LuanException {
+	public void update_in_transaction(Luan luan,LuanFunction fn) throws IOException, LuanException {
 		boolean commit = !writeLock.isHeldByCurrentThread();
 		writeLock.lock();
 		try {
@@ -243,7 +242,7 @@
 		}
 	}
 
-	public void run_in_lock(LuanState luan,LuanFunction fn) throws IOException, LuanException {
+	public void run_in_lock(Luan luan,LuanFunction fn) throws IOException, LuanException {
 		if( writeLock.isHeldByCurrentThread() )
 			throw new RuntimeException();
 		writeLock.lock();
@@ -278,7 +277,7 @@
 		}
 	}
 
-	public synchronized long nextId(LuanState luan) throws LuanException, IOException {
+	public synchronized long nextId(Luan luan) throws LuanException, IOException {
 		if( ++id > idLim ) {
 			idLim += idBatch;
 			LuanTable doc = new LuanTable(luan);
@@ -314,7 +313,7 @@
 		return snapshotDeletionPolicy;
 	}
 
-	public Object snapshot(LuanState luan,LuanFunction fn) throws LuanException, IOException {
+	public Object snapshot(Luan luan,LuanFunction fn) throws LuanException, IOException {
 		IndexCommit ic = snapshotDeletionPolicy.snapshot();
 		try {
 			String dir = fileDir.toString();
@@ -357,7 +356,7 @@
 			this.searcher = searcher;
 		}
 
-		@Override public Object call(LuanState luan,Object[] args) throws LuanException {
+		@Override public Object call(Luan luan,Object[] args) throws LuanException {
 			try {
 				return toTable(luan,searcher.doc(docID));
 			} catch(IOException e) {
@@ -403,7 +402,7 @@
 		close(openSearcher());
 	}
 
-	public int advanced_search( final LuanState luan, String queryStr, LuanFunction fn, Integer n, String sortStr ) throws LuanException, IOException, ParseException {
+	public int advanced_search( final Luan luan, String queryStr, LuanFunction fn, Integer n, String sortStr ) throws LuanException, IOException, ParseException {
 		Utils.checkNotNull(queryStr);
 		Query query = SaneQueryParser.parseQuery(mfp,queryStr);
 		IndexSearcher searcher = threadLocalSearcher.get();
@@ -452,7 +451,7 @@
 		}
 	}
 
-	public Object search_in_transaction(LuanState luan,LuanFunction fn) throws LuanException, IOException {
+	public Object search_in_transaction(Luan luan,LuanFunction fn) throws LuanException, IOException {
 		if( threadLocalSearcher.get() != null )
 			throw new LuanException("can't nest search_in_transaction calls");
 		IndexSearcher searcher = openSearcher();
@@ -557,7 +556,7 @@
 		throw new LuanException("invalid field type for "+ifld);
 	}
 
-	private static LuanTable toTable(LuanState luan,Document doc) throws LuanException {
+	private static LuanTable toTable(Luan luan,Document doc) throws LuanException {
 		if( doc==null )
 			return null;
 		LuanTable table = new LuanTable(luan);
@@ -589,7 +588,7 @@
 		}
 	};
 
-	public LuanFunction highlighter(LuanState luan,String queryStr,LuanFunction formatter,final Integer fragmentSize,String dotdotdot) throws ParseException {
+	public LuanFunction highlighter(Luan luan,String queryStr,LuanFunction formatter,final Integer fragmentSize,String dotdotdot) throws ParseException {
 		Query query = SaneQueryParser.parseQuery(mfp,queryStr);
 		Formatter fmt = new Formatter() {
 			public String highlightTerm(String originalText,TokenGroup tokenGroup) {
@@ -609,7 +608,7 @@
 		final Highlighter hl = new Highlighter(fmt,queryScorer);
 		hl.setTextFragmenter( new NullFragmenter() );
 		return new LuanFunction() {
-			@Override public String call(LuanState luan,Object[] args) throws LuanException {
+			@Override public String call(Luan luan,Object[] args) throws LuanException {
 				String text = (String)args[0];
 				try {
 					if( chooser != null ) {