/*
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.lucene.index;
import org.apache.lucene.codecs.PostingsFormat; // javadocs
import org.apache.lucene.codecs.perfield.PerFieldPostingsFormat; // javadocs
import org.apache.lucene.store.Directory;
import org.apache.lucene.store.IOContext;
import org.apache.lucene.util.FixedBitSet;
import org.apache.lucene.util.InfoStream;
Holder class for common parameters used during write.
@lucene.experimental
/**
* Holder class for common parameters used during write.
* @lucene.experimental
*/
public class SegmentWriteState {
InfoStream
used for debugging messages. /** {@link InfoStream} used for debugging messages. */
public final InfoStream infoStream;
Directory
where this segment will be written to. /** {@link Directory} where this segment will be written
* to. */
public final Directory directory;
SegmentInfo
describing this segment. /** {@link SegmentInfo} describing this segment. */
public final SegmentInfo segmentInfo;
FieldInfos
describing all fields in this segment. /** {@link FieldInfos} describing all fields in this
* segment. */
public final FieldInfos fieldInfos;
Number of deleted documents set while flushing the
segment. /** Number of deleted documents set while flushing the
* segment. */
public int delCountOnFlush;
Number of only soft deleted documents set while flushing the
segment. /** Number of only soft deleted documents set while flushing the
* segment. */
public int softDelCountOnFlush;
Deletes and updates to apply while we are flushing the segment. A Term is
enrolled in here if it was deleted/updated at one point, and it's mapped to
the docIDUpto, meaning any docID < docIDUpto containing this term should
be deleted/updated.
/**
* Deletes and updates to apply while we are flushing the segment. A Term is
* enrolled in here if it was deleted/updated at one point, and it's mapped to
* the docIDUpto, meaning any docID < docIDUpto containing this term should
* be deleted/updated.
*/
public final BufferedUpdates segUpdates;
FixedBitSet
recording live documents; this is only set if there is one or more deleted documents. /** {@link FixedBitSet} recording live documents; this is
* only set if there is one or more deleted documents. */
public FixedBitSet liveDocs;
Unique suffix for any postings files written for this segment. PerFieldPostingsFormat
sets this for each of the postings formats it wraps. If you create a new PostingsFormat
then any files you write/read must be derived using this suffix (use IndexFileNames.segmentFileName(String, String, String)
). Note: the suffix must be either empty, or be a textual suffix contain exactly two parts (separated by underscore), or be a base36 generation. /** Unique suffix for any postings files written for this
* segment. {@link PerFieldPostingsFormat} sets this for
* each of the postings formats it wraps. If you create
* a new {@link PostingsFormat} then any files you
* write/read must be derived using this suffix (use
* {@link IndexFileNames#segmentFileName(String,String,String)}).
*
* Note: the suffix must be either empty, or be a textual suffix contain exactly two parts (separated by underscore), or be a base36 generation. */
public final String segmentSuffix;
IOContext
for all writes; you should pass this to Directory.createOutput(String, IOContext)
. /** {@link IOContext} for all writes; you should pass this
* to {@link Directory#createOutput(String,IOContext)}. */
public final IOContext context;
Sole constructor. /** Sole constructor. */
public SegmentWriteState(InfoStream infoStream, Directory directory, SegmentInfo segmentInfo, FieldInfos fieldInfos,
BufferedUpdates segUpdates, IOContext context) {
this(infoStream, directory, segmentInfo, fieldInfos, segUpdates, context, "");
}
Constructor which takes segment suffix.
See Also: - SegmentWriteState(InfoStream, Directory, SegmentInfo, FieldInfos, BufferedUpdates, IOContext)
/**
* Constructor which takes segment suffix.
*
* @see #SegmentWriteState(InfoStream, Directory, SegmentInfo, FieldInfos,
* BufferedUpdates, IOContext)
*/
public SegmentWriteState(InfoStream infoStream, Directory directory, SegmentInfo segmentInfo, FieldInfos fieldInfos,
BufferedUpdates segUpdates, IOContext context, String segmentSuffix) {
this.infoStream = infoStream;
this.segUpdates = segUpdates;
this.directory = directory;
this.segmentInfo = segmentInfo;
this.fieldInfos = fieldInfos;
assert assertSegmentSuffix(segmentSuffix);
this.segmentSuffix = segmentSuffix;
this.context = context;
}
Create a shallow copy of SegmentWriteState
with a new segment suffix. /** Create a shallow copy of {@link SegmentWriteState} with a new segment suffix. */
public SegmentWriteState(SegmentWriteState state, String segmentSuffix) {
infoStream = state.infoStream;
directory = state.directory;
segmentInfo = state.segmentInfo;
fieldInfos = state.fieldInfos;
context = state.context;
this.segmentSuffix = segmentSuffix;
segUpdates = state.segUpdates;
delCountOnFlush = state.delCountOnFlush;
liveDocs = state.liveDocs;
}
// currently only used by assert? clean up and make real check?
// either it's a segment suffix (_X_Y) or it's a parseable generation
// TODO: this is very confusing how ReadersAndUpdates passes generations via
// this mechanism, maybe add 'generation' explicitly to ctor create the 'actual suffix' here?
private boolean assertSegmentSuffix(String segmentSuffix) {
assert segmentSuffix != null;
if (!segmentSuffix.isEmpty()) {
int numParts = segmentSuffix.split("_").length;
if (numParts == 2) {
return true;
} else if (numParts == 1) {
Long.parseLong(segmentSuffix, Character.MAX_RADIX);
return true;
}
return false; // invalid
}
return true;
}
}