Interface TimeOrderedKeyValueBuffer

    • Method Detail

      • evictWhile

        void evictWhile​(java.util.function.Supplier<java.lang.Boolean> predicate,
                        java.util.function.Consumer<KeyValue<org.apache.kafka.common.utils.Bytes,​ContextualRecord>> callback)
      • put

        void put​(long time,
                 org.apache.kafka.common.utils.Bytes key,
                 ContextualRecord value)
      • numRecords

        int numRecords()
      • bufferSize

        long bufferSize()
      • minTimestamp

        long minTimestamp()