Package com.bakdata.kafka.streams.kstream

Interface TimeWindowedKStreamX<K,V>

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

  • Method Summary

    Modifier and Type
    Method
    Description
    <VR> KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VR>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator)
     
    <VR> KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VR>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, MaterializedX<K,VR,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    <VR> KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VR>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    <VR> KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VR>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Named named)
     
    <VR> KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VR>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,VR,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    <VR> KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VR>
    aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,Long>
    count()
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,Long>
    count(MaterializedX<K,Long,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,Long>
    count(org.apache.kafka.streams.kstream.Materialized<K,Long,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,Long>
    count(org.apache.kafka.streams.kstream.Named named)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,Long>
    count(org.apache.kafka.streams.kstream.Named named, MaterializedX<K,Long,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,Long>
    count(org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,Long,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    TimeWindowedKStreamX<K,V>
    emitStrategy(org.apache.kafka.streams.kstream.EmitStrategy emitStrategy)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,V>
    reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,V>
    reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, MaterializedX<K,V,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,V>
    reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,V>
    reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Named named)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,V>
    reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,V,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     
    KTableX<org.apache.kafka.streams.kstream.Windowed<K>,V>
    reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
     

  • Method Details

    • count

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,Long> count()
      Specified by:
      count in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>

    • count

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,Long> count(org.apache.kafka.streams.kstream.Named named)
      Specified by:
      count in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>

    • count

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,Long> count(org.apache.kafka.streams.kstream.Materialized<K,Long,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      count in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>

    • count

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,Long> count(MaterializedX<K,Long,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • count

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,Long> count(org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,Long,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      count in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>

    • count

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,Long> count(org.apache.kafka.streams.kstream.Named named, MaterializedX<K,Long,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • aggregate

      <VR> KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VR> aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>

    • aggregate

      <VR> KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VR> aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Named named)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>

    • aggregate

      <VR> KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VR> aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>

    • aggregate

      <VR> KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VR> aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, MaterializedX<K,VR,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • aggregate

      <VR> KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VR> aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,VR,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      aggregate in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>

    • aggregate

      <VR> KTableX<org.apache.kafka.streams.kstream.Windowed<K>,VR> aggregate(org.apache.kafka.streams.kstream.Initializer<VR> initializer, org.apache.kafka.streams.kstream.Aggregator<? super K,? super V,VR> aggregator, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,VR,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • reduce

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer)
      Specified by:
      reduce in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>

    • reduce

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Named named)
      Specified by:
      reduce in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>

    • reduce

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      reduce in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>

    • reduce

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, MaterializedX<K,V,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • reduce

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Named named, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      reduce in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>

    • reduce

      KTableX<org.apache.kafka.streams.kstream.Windowed<K>,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> reducer, org.apache.kafka.streams.kstream.Named named, MaterializedX<K,V,org.apache.kafka.streams.state.WindowStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      See Also:

    • emitStrategy

      TimeWindowedKStreamX<K,V> emitStrategy(org.apache.kafka.streams.kstream.EmitStrategy emitStrategy)
      Specified by:
      emitStrategy in interface org.apache.kafka.streams.kstream.TimeWindowedKStream<K,V>