Class BufferedUpdates

  • All Implemented Interfaces:
    Accountable

    class BufferedUpdates
    extends java.lang.Object
    implements Accountable
    Holds buffered deletes and updates, by docID, term or query for a single segment. This is used to hold buffered pending deletes and updates against the to-be-flushed segment. Once the deletes and updates are pushed (on flush in DocumentsWriter), they are converted to a FrozenBufferedUpdates instance and pushed to the BufferedUpdatesStream.
    • Field Detail

      • BYTES_PER_DEL_TERM

        static final int BYTES_PER_DEL_TERM
      • BYTES_PER_DEL_DOCID

        static final int BYTES_PER_DEL_DOCID
      • BYTES_PER_DEL_QUERY

        static final int BYTES_PER_DEL_QUERY
      • numTermDeletes

        final java.util.concurrent.atomic.AtomicInteger numTermDeletes
      • numFieldUpdates

        final java.util.concurrent.atomic.AtomicInteger numFieldUpdates
      • deleteTerms

        final java.util.Map<Term,​java.lang.Integer> deleteTerms
      • deleteQueries

        final java.util.Map<Query,​java.lang.Integer> deleteQueries
      • deleteDocIDs

        final java.util.List<java.lang.Integer> deleteDocIDs
      • MAX_INT

        public static final java.lang.Integer MAX_INT
      • bytesUsed

        private final Counter bytesUsed
      • fieldUpdatesBytesUsed

        final Counter fieldUpdatesBytesUsed
      • gen

        long gen
      • segmentName

        final java.lang.String segmentName
    • Constructor Detail

      • BufferedUpdates

        public BufferedUpdates​(java.lang.String segmentName)
    • Method Detail

      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • addQuery

        public void addQuery​(Query query,
                             int docIDUpto)
      • addDocID

        public void addDocID​(int docID)
      • addTerm

        public void addTerm​(Term term,
                            int docIDUpto)
      • clearDeleteTerms

        void clearDeleteTerms()
      • clear

        void clear()
      • any

        boolean any()
      • ramBytesUsed

        public long ramBytesUsed()
        Description copied from interface: Accountable
        Return the memory usage of this object in bytes. Negative values are illegal.
        Specified by:
        ramBytesUsed in interface Accountable
      • clearDeletedDocIds

        void clearDeletedDocIds()