Interface TimeOrderedKeyValueBuffer<K,​V>

    • Method Detail

      • setSerdesIfNull

        void setSerdesIfNull​(org.apache.kafka.common.serialization.Serde<K> keySerde,
                             org.apache.kafka.common.serialization.Serde<V> valueSerde)
      • numRecords

        int numRecords()
      • bufferSize

        long bufferSize()
      • minTimestamp

        long minTimestamp()