
public abstract class OLuceneIndexEngineAbstract<V> extends OSharedResourceAdaptiveExternal implements OLuceneIndexEngine, OOrientListener
OIndexEngine.ValuesTransformer| Modifier and Type | Field and Description |
|---|---|
protected boolean |
automatic |
protected AtomicBoolean |
closed |
protected String |
clusterIndexName |
protected Map<String,Boolean> |
collectionFields |
protected TimerTask |
commitTask |
protected OIndexDefinition |
index |
static String |
KEY |
protected ODocument |
metadata |
protected org.apache.lucene.index.TrackingIndexWriter |
mgrWriter |
protected String |
name |
protected org.apache.lucene.search.ControlledRealTimeReopenThread |
nrt |
static String |
OLUCENE_BASE_DIR |
static String |
RID |
protected org.apache.lucene.search.SearcherManager |
searcherManager |
static String |
STORED |
protected org.apache.lucene.util.Version |
version |
| Constructor and Description |
|---|
OLuceneIndexEngineAbstract(String indexName) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
addDocument(org.apache.lucene.document.Document doc) |
OLuceneTxChanges |
buildTxChanges() |
void |
clear() |
void |
close() |
protected void |
closeIndex() |
protected void |
commit() |
void |
create(OBinarySerializer valueSerializer,
boolean isAutomatic,
OType[] keyTypes,
boolean nullPointerSupport,
OBinarySerializer keySerializer,
int keySize,
Set<String> clustersToIndex,
Map<String,String> engineProperties,
ODocument metadata) |
protected abstract org.apache.lucene.index.IndexWriter |
createIndexWriter(org.apache.lucene.store.Directory directory) |
void |
delete() |
protected void |
deleteDocument(org.apache.lucene.search.Query query) |
org.apache.lucene.search.Query |
deleteQuery(Object key,
OIdentifiable value) |
void |
deleteWithoutLoad(String indexName) |
OIndexCursor |
descCursor(OIndexEngine.ValuesTransformer vValuesTransformer) |
void |
flush() |
protected ODatabaseDocumentInternal |
getDatabase() |
protected String |
getIndexBasePath(OLocalPaginatedStorage storageLocalAbstract) |
String |
getName() |
int |
getVersion() |
org.apache.lucene.analysis.Analyzer |
indexAnalyzer() |
String |
indexName() |
void |
init(String indexName,
String indexType,
OIndexDefinition indexDefinition,
boolean isAutomatic,
ODocument metadata) |
protected void |
internalDelete(String indexName) |
protected boolean |
isCollectionDelete() |
protected org.apache.lucene.document.Field.Store |
isToStore(String f) |
void |
load(String indexName,
OBinarySerializer valueSerializer,
boolean isAutomatic,
OBinarySerializer keySerializer,
OType[] keyTypes,
boolean nullPointerSupport,
int keySize,
Map<String,String> engineProperties) |
abstract void |
onRecordAddedToResultSet(QueryContext queryContext,
OContextualRecordId recordId,
org.apache.lucene.document.Document ret,
org.apache.lucene.search.ScoreDoc score) |
void |
onShutdown() |
void |
onStorageRegistered(OStorage storage) |
void |
onStorageUnregistered(OStorage storage) |
protected abstract org.apache.lucene.index.IndexWriter |
openIndexWriter(org.apache.lucene.store.Directory directory) |
org.apache.lucene.analysis.Analyzer |
queryAnalyzer() |
protected void |
release(org.apache.lucene.search.IndexSearcher searcher) |
boolean |
remove(Object key,
OIdentifiable value) |
org.apache.lucene.search.IndexSearcher |
searcher() |
static void |
sendLookupTime(String indexName,
OCommandContext context,
org.apache.lucene.search.TopDocs docs,
Integer limit,
long startFetching) |
static void |
sendTotalHits(String indexName,
OCommandContext context,
int totalHits) |
long |
size(OIndexEngine.ValuesTransformer transformer) |
long |
sizeInTx(OLuceneTxChanges changes) |
acquireExclusiveLock, acquireSharedLock, releaseExclusiveLock, releaseSharedLock, tryAcquireExclusiveLock, tryAcquireSharedLockaddUser, assertExclusiveLockHold, assertSharedLockHold, getUsers, isConcurrent, removeUserclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitbuildDocument, buildQuery, getInTxcontains, cursor, get, getFirstKey, getLastKey, hasRangeQuerySupport, iterateEntriesBetween, iterateEntriesMajor, iterateEntriesMinor, keyCursor, put, removepublic static final String RID
public static final String KEY
public static final String STORED
public static final String OLUCENE_BASE_DIR
protected org.apache.lucene.search.SearcherManager searcherManager
protected OIndexDefinition index
protected org.apache.lucene.index.TrackingIndexWriter mgrWriter
protected String name
protected String clusterIndexName
protected boolean automatic
protected org.apache.lucene.search.ControlledRealTimeReopenThread nrt
protected ODocument metadata
protected org.apache.lucene.util.Version version
protected TimerTask commitTask
protected AtomicBoolean closed
public OLuceneIndexEngineAbstract(String indexName)
public static void sendTotalHits(String indexName, OCommandContext context, int totalHits)
public static void sendLookupTime(String indexName, OCommandContext context, org.apache.lucene.search.TopDocs docs, Integer limit, long startFetching)
protected abstract org.apache.lucene.index.IndexWriter openIndexWriter(org.apache.lucene.store.Directory directory)
throws IOException
IOExceptionprotected void addDocument(org.apache.lucene.document.Document doc)
public void init(String indexName, String indexType, OIndexDefinition indexDefinition, boolean isAutomatic, ODocument metadata)
init in interface OIndexEngineprotected void commit()
protected abstract org.apache.lucene.index.IndexWriter createIndexWriter(org.apache.lucene.store.Directory directory)
throws IOException
IOExceptionpublic void flush()
flush in interface OIndexEnginepublic void create(OBinarySerializer valueSerializer, boolean isAutomatic, OType[] keyTypes, boolean nullPointerSupport, OBinarySerializer keySerializer, int keySize, Set<String> clustersToIndex, Map<String,String> engineProperties, ODocument metadata)
create in interface OIndexEnginepublic void delete()
delete in interface OIndexEnginepublic void deleteWithoutLoad(String indexName)
deleteWithoutLoad in interface OIndexEngineprotected void internalDelete(String indexName)
protected void closeIndex()
throws IOException
IOExceptionprotected ODatabaseDocumentInternal getDatabase()
protected String getIndexBasePath(OLocalPaginatedStorage storageLocalAbstract)
public void load(String indexName, OBinarySerializer valueSerializer, boolean isAutomatic, OBinarySerializer keySerializer, OType[] keyTypes, boolean nullPointerSupport, int keySize, Map<String,String> engineProperties)
load in interface OIndexEnginepublic void clear()
clear in interface OIndexEnginepublic void close()
close in interface OIndexEnginepublic OIndexCursor descCursor(OIndexEngine.ValuesTransformer vValuesTransformer)
descCursor in interface OIndexEnginepublic long size(OIndexEngine.ValuesTransformer transformer)
size in interface OIndexEngineprotected void release(org.apache.lucene.search.IndexSearcher searcher)
public int getVersion()
getVersion in interface OIndexEnginepublic String getName()
getName in interface OIndexEnginepublic String indexName()
indexName in interface OLuceneIndexEnginepublic abstract void onRecordAddedToResultSet(QueryContext queryContext, OContextualRecordId recordId, org.apache.lucene.document.Document ret, org.apache.lucene.search.ScoreDoc score)
onRecordAddedToResultSet in interface OLuceneIndexEnginepublic org.apache.lucene.analysis.Analyzer indexAnalyzer()
indexAnalyzer in interface OLuceneIndexEnginepublic org.apache.lucene.analysis.Analyzer queryAnalyzer()
queryAnalyzer in interface OLuceneIndexEnginepublic boolean remove(Object key, OIdentifiable value)
remove in interface OLuceneIndexEngineprotected void deleteDocument(org.apache.lucene.search.Query query)
protected boolean isCollectionDelete()
public org.apache.lucene.search.IndexSearcher searcher()
throws IOException
searcher in interface OLuceneIndexEngineIOExceptionpublic long sizeInTx(OLuceneTxChanges changes)
sizeInTx in interface OLuceneIndexEnginepublic OLuceneTxChanges buildTxChanges() throws IOException
buildTxChanges in interface OLuceneIndexEngineIOExceptionpublic org.apache.lucene.search.Query deleteQuery(Object key, OIdentifiable value)
deleteQuery in interface OLuceneIndexEngineprotected org.apache.lucene.document.Field.Store isToStore(String f)
public void onShutdown()
onShutdown in interface OOrientListeneronShutdown in interface OOrientShutdownListenerpublic void onStorageRegistered(OStorage storage)
onStorageRegistered in interface OOrientListenerpublic void onStorageUnregistered(OStorage storage)
onStorageUnregistered in interface OOrientListenerCopyright © 2009–2016 Orient Technologies. All rights reserved.