Package com.bakdata.kafka.streams.kstream

Interface KGroupedTableX<K,V>

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

  • Method Summary

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

  • Method Details

    • count

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

    • count

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

    • count

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

    • count

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

    • count

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

    • count

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

    • reduce

      KTableX<K,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> adder, org.apache.kafka.streams.kstream.Reducer<V> subtractor, org.apache.kafka.streams.kstream.Materialized<K,V,org.apache.kafka.streams.state.KeyValueStore<org.apache.kafka.common.utils.Bytes,byte[]>> materialized)
      Specified by:
      reduce in interface org.apache.kafka.streams.kstream.KGroupedTable<K,V>

    • reduce

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

    • reduce

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

    • reduce

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

    • reduce

      KTableX<K,V> reduce(org.apache.kafka.streams.kstream.Reducer<V> adder, org.apache.kafka.streams.kstream.Reducer<V> subtractor)
      Specified by:
      reduce in interface org.apache.kafka.streams.kstream.KGroupedTable<K,V>

    • aggregate

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

    • aggregate

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

    • aggregate

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

    • aggregate

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

    • aggregate

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

    • aggregate

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