Java 类org.apache.lucene.index.IndexWriter.Event 实例源码

DocumentsWriter(IndexWriter writer, LiveIndexWriterConfig config, Directory directory) {
  this.directory = directory;
  this.config = config;
  this.infoStream = config.getInfoStream();
  this.perThreadPool = config.getIndexerThreadPool();
  flushPolicy = config.getFlushPolicy();
  this.writer = writer;
  this.events = new ConcurrentLinkedQueue<Event>();
  flushControl = new DocumentsWriterFlushControl(this, config, writer.bufferedUpdatesStream);
}

DocumentsWriter(IndexWriter writer, LiveIndexWriterConfig config, Directory directory) {
  this.directory = directory;
  this.config = config;
  this.infoStream = config.getInfoStream();
  this.perThreadPool = config.getIndexerThreadPool();
  flushPolicy = config.getFlushPolicy();
  this.writer = writer;
  this.events = new ConcurrentLinkedQueue<Event>();
  flushControl = new DocumentsWriterFlushControl(this, config, writer.bufferedUpdatesStream);
}

DocumentsWriter(IndexWriter writer, LiveIndexWriterConfig config, Directory directory) {
  this.directory = directory;
  this.config = config;
  this.infoStream = config.getInfoStream();
  this.perThreadPool = config.getIndexerThreadPool();
  flushPolicy = config.getFlushPolicy();
  this.writer = writer;
  this.events = new ConcurrentLinkedQueue<Event>();
  flushControl = new DocumentsWriterFlushControl(this, config, writer.bufferedUpdatesStream);
}

private void putEvent(Event event) {
  events.add(event);
}

public Queue<Event> eventQueue() {
  return events;
}

private void putEvent(Event event) {
  events.add(event);
}

public Queue<Event> eventQueue() {
  return events;
}

private void putEvent(Event event) {
  events.add(event);
}

public Queue<Event> eventQueue() {
  return events;
}

private void putEvent(Event event) {
  events.add(event);
}

public Queue<Event> eventQueue() {
  return events;
}

private void putEvent(Event event) {
  events.add(event);
}

public Queue<Event> eventQueue() {
  return events;
}

private void putEvent(Event event) {
  events.add(event);
}

public Queue<Event> eventQueue() {
  return events;
}