Class SessionKeySchema

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static <K> Windowed<K> from​(byte[] binaryKey, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, java.lang.String topic)  
      static Windowed<org.apache.kafka.common.utils.Bytes> from​(org.apache.kafka.common.utils.Bytes bytesKey)  
      static <K> Windowed<K> from​(Windowed<org.apache.kafka.common.utils.Bytes> keyBytes, org.apache.kafka.common.serialization.Deserializer<K> keyDeserializer, java.lang.String topic)  
      org.apache.kafka.streams.state.internals.HasNextCondition hasNextCondition​(org.apache.kafka.common.utils.Bytes binaryKeyFrom, org.apache.kafka.common.utils.Bytes binaryKeyTo, long from, long to)
      Create an implementation of HasNextCondition that knows when to stop iterating over the KeyValueSegments.
      org.apache.kafka.common.utils.Bytes lowerRange​(org.apache.kafka.common.utils.Bytes key, long from)
      Given a range of record keys and a time, construct a Segmented key that represents the lower range of keys to search when performing range queries.
      org.apache.kafka.common.utils.Bytes lowerRangeFixedSize​(org.apache.kafka.common.utils.Bytes key, long from)
      Given a range of fixed size record keys and a time, construct a Segmented key that represents the lower range of keys to search when performing range queries.
      <S extends Segment>
      java.util.List<S>
      segmentsToSearch​(org.apache.kafka.streams.state.internals.Segments<S> segments, long from, long to)
      Used during SegmentedBytesStore.fetch(Bytes, long, long) operations to determine which segments should be scanned.
      long segmentTimestamp​(org.apache.kafka.common.utils.Bytes key)
      Extract the timestamp of the segment from the key.
      static org.apache.kafka.common.utils.Bytes toBinary​(org.apache.kafka.common.utils.Bytes key, long startTime, long endTime)  
      static <K> byte[] toBinary​(Windowed<K> sessionKey, org.apache.kafka.common.serialization.Serializer<K> serializer, java.lang.String topic)  
      static org.apache.kafka.common.utils.Bytes toBinary​(Windowed<org.apache.kafka.common.utils.Bytes> sessionKey)  
      org.apache.kafka.common.utils.Bytes upperRange​(org.apache.kafka.common.utils.Bytes key, long to)
      Given a range of record keys and a time, construct a Segmented key that represents the upper range of keys to search when performing range queries.
      org.apache.kafka.common.utils.Bytes upperRangeFixedSize​(org.apache.kafka.common.utils.Bytes key, long to)
      Given a range of fixed size record keys and a time, construct a Segmented key that represents the upper range of keys to search when performing range queries.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait