Package com.bakdata.kafka.streams.kstream

Interface SessionWindowedCogroupedKStreamX<K,VOut>

Type Parameters:
K - type of keys
VOut - type of values
All Superinterfaces:
org.apache.kafka.streams.kstream.SessionWindowedCogroupedKStream<K,VOut>
public interface SessionWindowedCogroupedKStreamX<K,VOut> extends org.apache.kafka.streams.kstream.SessionWindowedCogroupedKStream<K,VOut>
Extends the SessionWindowedCogroupedKStream interface by adding methods to simplify Serde configuration, error handling, and topic access

  • Method Summary

    Modifier and Type
    Method
    Description
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VOut>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Merger<? super K,VOut> sessionMerger)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VOut>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Merger<? super K,VOut> sessionMerger, MaterializedX<K,VOut,org.apache.kafka.streams.state.SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VOut>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Merger<? super K,VOut> sessionMerger, org.apache.kafka.streams.kstream.Materialized<K,VOut,org.apache.kafka.streams.state.SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VOut>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Merger<? super K,VOut> sessionMerger, org.apache.kafka.streams.kstream.Named named)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VOut>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Merger<? super K,VOut> sessionMerger, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,VOut,org.apache.kafka.streams.state.SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VOut>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Merger<? super K,VOut> sessionMerger, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VOut,org.apache.kafka.streams.state.SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     

  • Method Details

    • aggregate

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VOut> aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Merger<? super K,VOut> sessionMerger)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.SessionWindowedCogroupedKStream<K,VOut>

    • aggregate

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VOut> aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Merger<? super K,VOut> sessionMerger, org.apache.kafka.streams.kstream.Named named)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.SessionWindowedCogroupedKStream<K,VOut>

    • aggregate

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VOut> aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Merger<? super K,VOut> sessionMerger, org.apache.kafka.streams.kstream.Materialized<K,VOut,org.apache.kafka.streams.state.SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.SessionWindowedCogroupedKStream<K,VOut>

    • aggregate

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VOut> aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Merger<? super K,VOut> sessionMerger, MaterializedX<K,VOut,org.apache.kafka.streams.state.SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • aggregate

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VOut> aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Merger<? super K,VOut> sessionMerger, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VOut,org.apache.kafka.streams.state.SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.SessionWindowedCogroupedKStream<K,VOut>

    • aggregate

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VOut> aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Merger<? super K,VOut> sessionMerger, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,VOut,org.apache.kafka.streams.state.SessionStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also: