本文整理了Java中proj.zoie.impl.indexing.ZoieSystem类的一些代码示例，展示了ZoieSystem类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZoieSystem类的具体详情如下：
包路径：proj.zoie.impl.indexing.ZoieSystem
类名称：ZoieSystem

ZoieSystem介绍

[英]Zoie system, main class.
[中]Zoie系统，主课。

代码示例

代码示例来源：origin: senseidb/zoie

ZoieSystem<R, D> createZoie(DirectoryManager dirmgr) {
 return new ZoieSystem<R, D>(dirmgr, _interpreter, _decorator, _zConfig);
}

代码示例来源：origin: senseidb/zoie

public ZoieIndexingStatusAdmin(ZoieSystem<?, ?> zoieSystem) {
 _zoieSystem = zoieSystem;
 _zoieSystem.addIndexingEventListener(this);
 _startTime = 0L;
 _endTime = 0L;
 _leftOver = 0;
 _size = 0;
 _totalSize = 0;
 _totalTime = 0;
 _diskVersion = null;
}

代码示例来源：origin: com.senseidb.zoie/zoie-core

/**
 * @deprecated use {@link ZoieSystem#buildDefaultInstance(File, ZoieIndexableInterpreter, ZoieConfig)}
 * @param idxDir
 * @param interpreter
 * @param batchSize
 * @param batchDelay
 * @param realtime
 * @param versionComparator
 */
@Deprecated
public static <D> ZoieSystem<IndexReader, D> buildDefaultInstance(File idxDir,
  ZoieIndexableInterpreter<D> interpreter, int batchSize, long batchDelay, boolean realtime,
  Comparator<String> versionComparator) {
 return buildDefaultInstance(idxDir, interpreter, new StandardAnalyzer(Version.LUCENE_43),
  new DefaultSimilarity(), batchSize, batchDelay, realtime, versionComparator);
}

代码示例来源：origin: com.senseidb.zoie/zoie-core

zoie.shutdown();
zoie.shutdown();
 long flushwait = 200000L;
 try {
  zoie.flushEvents(flushwait);
  zoie.getAdminMBean().setUseCompoundFile(true);
  zoie.getAdminMBean().optimize(1);
  break;
 } catch (IOException e) {
  log.error("pre-shutdown optimization " + zoie.getAdminMBean().getIndexDir()
    + " Should investigate. But move on now.", e);
  break;
   break;
  } else {
   log.info("pre-shutdown optimization " + zoie.getAdminMBean().getIndexDir()
     + " flushing processing " + flushwait + "ms elapsed");
zoie.shutdown();

代码示例来源：origin: senseidb/zoie

private DirectoryReader getArchive(ZoieSystem<R, D> zoie) throws CorruptIndexException, IOException {
  String dirName = zoie.getAdminMBean().getIndexDir();
  Directory dir = new SimpleFSDirectory(new File(dirName));
  DirectoryReader reader = null;
  if (DirectoryReader.indexExists(dir)) {
   reader = DirectoryReader.open(dir);
  } else {
   log.info("empty index " + dirName);
   reader = null;
  }
  return reader;
 }
}

代码示例来源：origin: com.senseidb/sensei-core

ZoieSystem<BoboSegmentReader, T> zoie = new ZoieSystem<BoboSegmentReader, T>(dirMgr,
  _interpreter, _indexReaderDecorator, _zoieConfig);
if (_purgeFilter != null) {
 zoie.setPurgeFilter(_purgeFilter);
zoie.addIndexingEventListener(new IndexingEventListener() {

代码示例来源：origin: senseidb/zoie

protected List<ZoieSystem<R, D>> loadArchiveZoies() {
 List<ZoieSystem<R, D>> archives = new ArrayList<ZoieSystem<R, D>>();
 long t0 = System.currentTimeMillis();
 List<File> dirs = _dirMgrFactory.getAllArchivedDirs();
 for (File dir : dirs) {
  try {
   DirectoryManager dirMgr = new DefaultDirectoryManager(dir, _dirMgrFactory.getMode());
   ZoieSystem<R, D> zoie = new ZoieSystem<R, D>(dirMgr, _interpreter, _decorator, _zConfig);
   zoie.start();
   archives.add(zoie);
  } catch (Exception e) {
   log.error("Load index: " + dir + " failed.", e);
  }
 }
 log.info("load " + dirs.size() + " archived indices of " + getSizeBytes() + " bytes in "
   + (System.currentTimeMillis() - t0) + "ms");
 return archives;
}

代码示例来源：origin: com.senseidb.zoie/zoie-core

_currentZoie.consume(data);
} else {
 _currentZoie.start();
 clearFromArchives(data);
 _currentZoie.consume(data);

代码示例来源：origin: com.linkedin.zoie/zoie-core

@Override
public void flushEvents(long timeout) throws ZoieException
{
  _currentZoie.flushEvents(timeout);
}

代码示例来源：origin: senseidb/zoie

private void clearFromArchives(Collection<DataEvent<D>> data) throws ZoieException {
 if (_dirMgrFactory.getScheduler().isAppendOnly()) return;
 if (data != null && data.size() > 0) {
  List<DataEvent<D>> deletes = new ArrayList<DataEvent<D>>(data.size());
  for (DataEvent<D> event : data) {
   deletes.add(new DataEvent<D>(event.getData(), event.getVersion(), true));
  }
  for (ZoieSystem<R, D> zoie : _readerMgr.getArchiveZoies()) {
   zoie.consume(deletes);
  }
 }
}

代码示例来源：origin: com.linkedin.zoie/zoie-core

@Override
public String getCurrentDiskVersion() throws IOException
{
 return hourglass.getCurrentZoie().getCurrentDiskVersion();
}

代码示例来源：origin: com.linkedin.zoie/zoie-core

@Override
public int getCurrentDiskBatchSize()
{
 return hourglass.getCurrentZoie().getCurrentDiskBatchSize();
}

代码示例来源：origin: senseidb/zoie

public int getCurrentMemBatchSize() {
 return getCurrentBatchSize();
}

代码示例来源：origin: com.senseidb.zoie/zoie-core

@Override
public int getCurrentMemBatchSize() {
 return hourglass.getCurrentZoie().getCurrentMemBatchSize();
}

代码示例来源：origin: senseidb/zoie

zoie.shutdown();
zoie.shutdown();
 long flushwait = 200000L;
 try {
  zoie.flushEvents(flushwait);
  zoie.getAdminMBean().setUseCompoundFile(true);
  zoie.getAdminMBean().optimize(1);
  break;
 } catch (IOException e) {
  log.error("pre-shutdown optimization " + zoie.getAdminMBean().getIndexDir()
    + " Should investigate. But move on now.", e);
  break;
   break;
  } else {
   log.info("pre-shutdown optimization " + zoie.getAdminMBean().getIndexDir()
     + " flushing processing " + flushwait + "ms elapsed");
zoie.shutdown();

代码示例来源：origin: com.linkedin.zoie/zoie-core

@Override
public int getNumLargeSegments()
{
 return hourglass.getCurrentZoie().getAdminMBean().getNumLargeSegments();
}

代码示例来源：origin: com.senseidb.zoie/zoie-core

protected List<ZoieSystem<R, D>> loadArchiveZoies() {
 List<ZoieSystem<R, D>> archives = new ArrayList<ZoieSystem<R, D>>();
 long t0 = System.currentTimeMillis();
 List<File> dirs = _dirMgrFactory.getAllArchivedDirs();
 for (File dir : dirs) {
  try {
   DirectoryManager dirMgr = new DefaultDirectoryManager(dir, _dirMgrFactory.getMode());
   ZoieSystem<R, D> zoie = new ZoieSystem<R, D>(dirMgr, _interpreter, _decorator, _zConfig);
   zoie.start();
   archives.add(zoie);
  } catch (Exception e) {
   log.error("Load index: " + dir + " failed.", e);
  }
 }
 log.info("load " + dirs.size() + " archived indices of " + getSizeBytes() + " bytes in "
   + (System.currentTimeMillis() - t0) + "ms");
 return archives;
}

代码示例来源：origin: senseidb/zoie

_currentZoie.consume(data);
} else {
 _currentZoie.start();
 clearFromArchives(data);
 _currentZoie.consume(data);

代码示例来源：origin: com.senseidb.zoie/zoie-core

@Override
public void flushEvents(long timeout) throws ZoieException {
 _currentZoie.flushEvents(timeout);
}

代码示例来源：origin: com.senseidb.zoie/zoie-core

private void clearFromArchives(Collection<DataEvent<D>> data) throws ZoieException {
 if (_dirMgrFactory.getScheduler().isAppendOnly()) return;
 if (data != null && data.size() > 0) {
  List<DataEvent<D>> deletes = new ArrayList<DataEvent<D>>(data.size());
  for (DataEvent<D> event : data) {
   deletes.add(new DataEvent<D>(event.getData(), event.getVersion(), true));
  }
  for (ZoieSystem<R, D> zoie : _readerMgr.getArchiveZoies()) {
   zoie.consume(deletes);
  }
 }
}