Package com.bakdata.kafka.streams.kstream

Class StoresX

java.lang.Object
com.bakdata.kafka.streams.kstream.StoresX
public class StoresX extends Object
Use Preconfigured to lazily configure Serde for Stores using Configurator

  • Constructor Summary

    Constructors
    Constructor
    Description
    StoresX(@NonNull com.bakdata.kafka.Configurator configurator)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.KeyValueStore<K,V>>
    keyValueStoreBuilder(org.apache.kafka.streams.state.KeyValueBytesStoreSupplier supplier, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
     
    <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.KeyValueStore<K,V>>
    keyValueStoreBuilder(org.apache.kafka.streams.state.KeyValueBytesStoreSupplier supplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
     
    <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.SessionStore<K,V>>
    sessionStoreBuilder(org.apache.kafka.streams.state.SessionBytesStoreSupplier supplier, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
     
    <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.SessionStore<K,V>>
    sessionStoreBuilder(org.apache.kafka.streams.state.SessionBytesStoreSupplier supplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
     
    <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.TimestampedKeyValueStore<K,V>>
    timestampedKeyValueStoreBuilder(org.apache.kafka.streams.state.KeyValueBytesStoreSupplier supplier, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
     
    <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.TimestampedKeyValueStore<K,V>>
    timestampedKeyValueStoreBuilder(org.apache.kafka.streams.state.KeyValueBytesStoreSupplier supplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
     
    <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.TimestampedWindowStore<K,V>>
    timestampedWindowStoreBuilder(org.apache.kafka.streams.state.WindowBytesStoreSupplier supplier, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
     
    <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.TimestampedWindowStore<K,V>>
    timestampedWindowStoreBuilder(org.apache.kafka.streams.state.WindowBytesStoreSupplier supplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
     
    <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.VersionedKeyValueStore<K,V>>
    versionedKeyValueStoreBuilder(org.apache.kafka.streams.state.VersionedBytesStoreSupplier supplier, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
     
    <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.VersionedKeyValueStore<K,V>>
    versionedKeyValueStoreBuilder(org.apache.kafka.streams.state.VersionedBytesStoreSupplier supplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
     
    <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.WindowStore<K,V>>
    windowStoreBuilder(org.apache.kafka.streams.state.WindowBytesStoreSupplier supplier, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
     
    <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.WindowStore<K,V>>
    windowStoreBuilder(org.apache.kafka.streams.state.WindowBytesStoreSupplier supplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • StoresX

      public StoresX(@NonNull @NonNull com.bakdata.kafka.Configurator configurator)

  • Method Details

    • sessionStoreBuilder

      public <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.SessionStore<K,V>> sessionStoreBuilder(org.apache.kafka.streams.state.SessionBytesStoreSupplier supplier, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
      See Also:
      • Stores.sessionStoreBuilder(SessionBytesStoreSupplier, Serde, Serde)

    • sessionStoreBuilder

      public <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.SessionStore<K,V>> sessionStoreBuilder(org.apache.kafka.streams.state.SessionBytesStoreSupplier supplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
      See Also:
      • Stores.sessionStoreBuilder(SessionBytesStoreSupplier, Serde, Serde)

    • timestampedWindowStoreBuilder

      public <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.TimestampedWindowStore<K,V>> timestampedWindowStoreBuilder(org.apache.kafka.streams.state.WindowBytesStoreSupplier supplier, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
      See Also:
      • Stores.timestampedWindowStoreBuilder(WindowBytesStoreSupplier, Serde, Serde)

    • timestampedWindowStoreBuilder

      public <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.TimestampedWindowStore<K,V>> timestampedWindowStoreBuilder(org.apache.kafka.streams.state.WindowBytesStoreSupplier supplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
      See Also:
      • Stores.timestampedWindowStoreBuilder(WindowBytesStoreSupplier, Serde, Serde)

    • windowStoreBuilder

      public <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.WindowStore<K,V>> windowStoreBuilder(org.apache.kafka.streams.state.WindowBytesStoreSupplier supplier, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
      See Also:
      • Stores.windowStoreBuilder(WindowBytesStoreSupplier, Serde, Serde)

    • windowStoreBuilder

      public <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.WindowStore<K,V>> windowStoreBuilder(org.apache.kafka.streams.state.WindowBytesStoreSupplier supplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
      See Also:
      • Stores.windowStoreBuilder(WindowBytesStoreSupplier, Serde, Serde)

    • versionedKeyValueStoreBuilder

      public <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.VersionedKeyValueStore<K,V>> versionedKeyValueStoreBuilder(org.apache.kafka.streams.state.VersionedBytesStoreSupplier supplier, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
      See Also:
      • Stores.versionedKeyValueStoreBuilder(VersionedBytesStoreSupplier, Serde, Serde)

    • versionedKeyValueStoreBuilder

      public <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.VersionedKeyValueStore<K,V>> versionedKeyValueStoreBuilder(org.apache.kafka.streams.state.VersionedBytesStoreSupplier supplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
      See Also:
      • Stores.versionedKeyValueStoreBuilder(VersionedBytesStoreSupplier, Serde, Serde)

    • timestampedKeyValueStoreBuilder

      public <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.TimestampedKeyValueStore<K,V>> timestampedKeyValueStoreBuilder(org.apache.kafka.streams.state.KeyValueBytesStoreSupplier supplier, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
      See Also:
      • Stores.timestampedKeyValueStoreBuilder(KeyValueBytesStoreSupplier, Serde, Serde)

    • timestampedKeyValueStoreBuilder

      public <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.TimestampedKeyValueStore<K,V>> timestampedKeyValueStoreBuilder(org.apache.kafka.streams.state.KeyValueBytesStoreSupplier supplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
      See Also:
      • Stores.timestampedKeyValueStoreBuilder(KeyValueBytesStoreSupplier, Serde, Serde)

    • keyValueStoreBuilder

      public <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.KeyValueStore<K,V>> keyValueStoreBuilder(org.apache.kafka.streams.state.KeyValueBytesStoreSupplier supplier, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<K>> keySerde, com.bakdata.kafka.Preconfigured<? extends org.apache.kafka.common.serialization.Serde<V>> valueSerde)
      See Also:
      • Stores.keyValueStoreBuilder(KeyValueBytesStoreSupplier, Serde, Serde)

    • keyValueStoreBuilder

      public <K, V> org.apache.kafka.streams.state.StoreBuilder<org.apache.kafka.streams.state.KeyValueStore<K,V>> keyValueStoreBuilder(org.apache.kafka.streams.state.KeyValueBytesStoreSupplier supplier, org.apache.kafka.common.serialization.Serde<K> keySerde, org.apache.kafka.common.serialization.Serde<V> valueSerde)
      See Also:
      • Stores.keyValueStoreBuilder(KeyValueBytesStoreSupplier, Serde, Serde)