class BufferedUpdates
extends java.lang.Object
FrozenBufferedUpdates
instance and
pushed to the BufferedUpdatesStream
.Modifier and Type | Field and Description |
---|---|
(package private) java.util.Map<java.lang.String,java.util.LinkedHashMap<Term,DocValuesUpdate.BinaryDocValuesUpdate>> |
binaryUpdates |
(package private) static int |
BYTES_PER_BINARY_FIELD_ENTRY |
(package private) static int |
BYTES_PER_BINARY_UPDATE_ENTRY |
(package private) static int |
BYTES_PER_DEL_DOCID |
(package private) static int |
BYTES_PER_DEL_QUERY |
(package private) static int |
BYTES_PER_DEL_TERM |
(package private) static int |
BYTES_PER_NUMERIC_FIELD_ENTRY |
(package private) static int |
BYTES_PER_NUMERIC_UPDATE_ENTRY |
(package private) java.util.concurrent.atomic.AtomicLong |
bytesUsed |
(package private) java.util.List<java.lang.Integer> |
deleteDocIDs |
(package private) java.util.Map<Query,java.lang.Integer> |
deleteQueries |
(package private) java.util.Map<Term,java.lang.Integer> |
deleteTerms |
(package private) long |
gen |
static java.lang.Integer |
MAX_INT |
(package private) java.util.concurrent.atomic.AtomicInteger |
numBinaryUpdates |
(package private) java.util.Map<java.lang.String,java.util.LinkedHashMap<Term,DocValuesUpdate.NumericDocValuesUpdate>> |
numericUpdates |
(package private) java.util.concurrent.atomic.AtomicInteger |
numNumericUpdates |
(package private) java.util.concurrent.atomic.AtomicInteger |
numTermDeletes |
(package private) java.lang.String |
segmentName |
private static boolean |
VERBOSE_DELETES |
Constructor and Description |
---|
BufferedUpdates(java.lang.String segmentName) |
Modifier and Type | Method and Description |
---|---|
void |
addBinaryUpdate(DocValuesUpdate.BinaryDocValuesUpdate update,
int docIDUpto) |
void |
addDocID(int docID) |
void |
addNumericUpdate(DocValuesUpdate.NumericDocValuesUpdate update,
int docIDUpto) |
void |
addQuery(Query query,
int docIDUpto) |
void |
addTerm(Term term,
int docIDUpto) |
(package private) boolean |
any() |
(package private) void |
clear() |
(package private) void |
clearDeleteTerms() |
java.lang.String |
toString() |
static final int BYTES_PER_DEL_TERM
static final int BYTES_PER_DEL_DOCID
static final int BYTES_PER_DEL_QUERY
static final int BYTES_PER_NUMERIC_FIELD_ENTRY
static final int BYTES_PER_NUMERIC_UPDATE_ENTRY
static final int BYTES_PER_BINARY_FIELD_ENTRY
static final int BYTES_PER_BINARY_UPDATE_ENTRY
final java.util.concurrent.atomic.AtomicInteger numTermDeletes
final java.util.concurrent.atomic.AtomicInteger numNumericUpdates
final java.util.concurrent.atomic.AtomicInteger numBinaryUpdates
final java.util.Map<Term,java.lang.Integer> deleteTerms
final java.util.Map<Query,java.lang.Integer> deleteQueries
final java.util.List<java.lang.Integer> deleteDocIDs
final java.util.Map<java.lang.String,java.util.LinkedHashMap<Term,DocValuesUpdate.NumericDocValuesUpdate>> numericUpdates
final java.util.Map<java.lang.String,java.util.LinkedHashMap<Term,DocValuesUpdate.BinaryDocValuesUpdate>> binaryUpdates
public static final java.lang.Integer MAX_INT
final java.util.concurrent.atomic.AtomicLong bytesUsed
private static final boolean VERBOSE_DELETES
long gen
final java.lang.String segmentName
public java.lang.String toString()
toString
in class java.lang.Object
public void addQuery(Query query, int docIDUpto)
public void addDocID(int docID)
public void addTerm(Term term, int docIDUpto)
public void addNumericUpdate(DocValuesUpdate.NumericDocValuesUpdate update, int docIDUpto)
public void addBinaryUpdate(DocValuesUpdate.BinaryDocValuesUpdate update, int docIDUpto)
void clearDeleteTerms()
void clear()
boolean any()