org.apache.lucene.index

Class DocumentsWriterFlushQueue.FlushTicket

java.lang.Object

org.apache.lucene.index.DocumentsWriterFlushQueue.FlushTicket

Direct Known Subclasses:

DocumentsWriterFlushQueue.GlobalDeletesTicket, DocumentsWriterFlushQueue.SegmentFlushTicket

Enclosing class:

DocumentsWriterFlushQueue

abstract static class DocumentsWriterFlushQueue.FlushTicket
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected FrozenBufferedUpdates	frozenUpdates
protected boolean	published

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	FlushTicket(FrozenBufferedUpdates frozenUpdates)

Method Summary

Modifier and Type	Method and Description
protected abstract boolean	canPublish()
protected void	finishFlush(IndexWriter indexWriter, DocumentsWriterPerThread.FlushedSegment newSegment, FrozenBufferedUpdates bufferedUpdates)
protected abstract void	publish(IndexWriter writer)
protected void	publishFlushedSegment(IndexWriter indexWriter, DocumentsWriterPerThread.FlushedSegment newSegment, FrozenBufferedUpdates globalPacket) Publishes the flushed segment, segment private deletes (if any) and its associated global delete (if present) to IndexWriter.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

frozenUpdates

protected FrozenBufferedUpdates frozenUpdates

published

protected boolean published

Constructor Detail

FlushTicket

protected FlushTicket(FrozenBufferedUpdates frozenUpdates)

Method Detail

publish

protected abstract void publish(IndexWriter writer)
                         throws java.io.IOException

Throws:

java.io.IOException

canPublish

protected abstract boolean canPublish()

publishFlushedSegment

protected final void publishFlushedSegment(IndexWriter indexWriter,
                                           DocumentsWriterPerThread.FlushedSegment newSegment,
                                           FrozenBufferedUpdates globalPacket)
                                    throws java.io.IOException

Publishes the flushed segment, segment private deletes (if any) and its associated global delete (if present) to IndexWriter. The actual publishing operation is synced on IW -> BDS so that the SegmentInfo's delete generation is always GlobalPacket_deleteGeneration + 1

Throws:

java.io.IOException

finishFlush

protected final void finishFlush(IndexWriter indexWriter,
                                 DocumentsWriterPerThread.FlushedSegment newSegment,
                                 FrozenBufferedUpdates bufferedUpdates)
                          throws java.io.IOException

Throws:

java.io.IOException