Package com.bakdata.kafka.streams.kstream

Interface CogroupedKStreamX<K,VOut>

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

  • Method Summary

    Modifier and Type
    Method
    Description
    KTableX<K,VOut>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer)
     
    KTableX<K,VOut>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, MaterializedX<K,VOut,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<K,VOut>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Materialized<K,VOut,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<K,VOut>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Named named)
     
    KTableX<K,VOut>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,VOut,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<K,VOut>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VOut,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    <VIn> CogroupedKStreamX<K,VOut>
    cogroup(org.apache.kafka.streams.kstream.KGroupedStream<K,VIn> groupedStream, org.apache.kafka.streams.kstream.Aggregator<? super K,? super VIn,VOut> aggregator)
     
    SessionWindowedCogroupedKStreamX<K,VOut>
    windowedBy(org.apache.kafka.streams.kstream.SessionWindows windows)
     
    TimeWindowedCogroupedKStreamX<K,VOut>
    windowedBy(org.apache.kafka.streams.kstream.SlidingWindows windows)
     
    <W extends org.apache.kafka.streams.kstream.Window>
    TimeWindowedCogroupedKStreamX<K,VOut>
    windowedBy(org.apache.kafka.streams.kstream.Windows<W> windows)
     

  • Method Details

    • cogroup

      <VIn> CogroupedKStreamX<K,VOut> cogroup(org.apache.kafka.streams.kstream.KGroupedStream<K,VIn> groupedStream, org.apache.kafka.streams.kstream.Aggregator<? super K,? super VIn,VOut> aggregator)
      Specified by:
      cogroup in interface org.apache.kafka.streams.kstream.CogroupedKStream<K,VOut>

    • aggregate

      KTableX<K,VOut> aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.CogroupedKStream<K,VOut>

    • aggregate

      KTableX<K,VOut> aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Named named)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.CogroupedKStream<K,VOut>

    • aggregate

      KTableX<K,VOut> aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Materialized<K,VOut,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.CogroupedKStream<K,VOut>

    • aggregate

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

    • aggregate

      KTableX<K,VOut> aggregate(org.apache.kafka.streams.kstream.Initializer<VOut> initializer, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VOut,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.CogroupedKStream<K,VOut>

    • aggregate

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

    • windowedBy

      <W extends org.apache.kafka.streams.kstream.Window> TimeWindowedCogroupedKStreamX<K,VOut> windowedBy(org.apache.kafka.streams.kstream.Windows<W> windows)
      Specified by:
      windowedBy in interface org.apache.kafka.streams.kstream.CogroupedKStream<K,VOut>

    • windowedBy

      TimeWindowedCogroupedKStreamX<K,VOut> windowedBy(org.apache.kafka.streams.kstream.SlidingWindows windows)
      Specified by:
      windowedBy in interface org.apache.kafka.streams.kstream.CogroupedKStream<K,VOut>

    • windowedBy

      SessionWindowedCogroupedKStreamX<K,VOut> windowedBy(org.apache.kafka.streams.kstream.SessionWindows windows)
      Specified by:
      windowedBy in interface org.apache.kafka.streams.kstream.CogroupedKStream<K,VOut>