java.lang.Object
- org.apache.kafka.streams.state.internals.InMemoryTimeOrderedKeyValueBuffer.Builder<K,V>

All Implemented Interfaces:: StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,V>>

Enclosing class:: InMemoryTimeOrderedKeyValueBuffer<K,V>

public static class InMemoryTimeOrderedKeyValueBuffer.Builder<K,V>
extends Object
implements StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,V>>

Constructor Summary

Constructors
Constructor Description

Builder(String storeName, Serde<K> keySerde, Serde<V> valSerde)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`InMemoryTimeOrderedKeyValueBuffer<K,V>`	`build()`	Build the store as defined by the builder.
`Map<String,String>`	`logConfig()`	Returns a Map containing any log configs that will be used when creating the changelog for the `StateStore`.
`boolean`	`loggingEnabled()`
`String`	`name()`	Return the name of this state store builder.
`StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,V>>`	`withCachingDisabled()`	As of 2.1, there's no way for users to directly interact with the buffer, so this method is implemented solely to be called by Streams (which it will do based on the `cache.max.bytes.buffering` config.
`StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,V>>`	`withCachingEnabled()`	As of 2.1, there's no way for users to directly interact with the buffer, so this method is implemented solely to be called by Streams (which it will do based on the `cache.max.bytes.buffering` config.
`StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,V>>`	`withLoggingDisabled()`	Disable the changelog for store built by this `StoreBuilder`.
`StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,V>>`	`withLoggingEnabled(Map<String,String> config)`	Maintain a changelog for any changes made to the store.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - Builder
```
public Builder(String storeName,
               Serde<K> keySerde,
               Serde<V> valSerde)
```
- Method Detail
  - withCachingEnabled
```
public StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,V>> withCachingEnabled()
```
    As of 2.1, there's no way for users to directly interact with the buffer, so this method is implemented solely to be called by Streams (which it will do based on the cache.max.bytes.buffering config.
    It's currently a no-op.
    
    Specified by:
    
    withCachingEnabled in interface StoreBuilder<K>
    
    Returns:
    
    this
  - withCachingDisabled
```
public StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,V>> withCachingDisabled()
```
    As of 2.1, there's no way for users to directly interact with the buffer, so this method is implemented solely to be called by Streams (which it will do based on the cache.max.bytes.buffering config.
    It's currently a no-op.
    
    Specified by:
    
    withCachingDisabled in interface StoreBuilder<K>
    
    Returns:
    
    this
  - withLoggingEnabled
```
public StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,V>> withLoggingEnabled(Map<String,String> config)
```
    Description copied from interface: StoreBuilder
    
    Maintain a changelog for any changes made to the store. Use the provided config to set the config of the changelog topic.
    
    Specified by:
    
    withLoggingEnabled in interface StoreBuilder<K>
    
    Parameters:
    
    config - config applied to the changelog topic
    
    Returns:
    
    this
  - withLoggingDisabled
```
public StoreBuilder<InMemoryTimeOrderedKeyValueBuffer<K,V>> withLoggingDisabled()
```
    Description copied from interface: StoreBuilder
    
    Disable the changelog for store built by this StoreBuilder. This will turn off fault-tolerance for your store. By default the changelog is enabled.
    
    Specified by:
    
    withLoggingDisabled in interface StoreBuilder<K>
    
    Returns:
    
    this
  - build
```
public InMemoryTimeOrderedKeyValueBuffer<K,V> build()
```
    Description copied from interface: StoreBuilder
    
    Build the store as defined by the builder.
    
    Specified by:
    
    build in interface StoreBuilder<K>
    
    Returns:
    
    the built StateStore
  - logConfig
```
public Map<String,String> logConfig()
```
    Description copied from interface: StoreBuilder
    
    Returns a Map containing any log configs that will be used when creating the changelog for the StateStore.
    Note: any unrecognized configs will be ignored by the Kafka brokers.
    
    Specified by:
    
    logConfig in interface StoreBuilder<K>
    
    Returns:
    
    Map containing any log configs to be used when creating the changelog for the StateStore If loggingEnabled returns false, this function will always return an empty map
  - loggingEnabled
```
public boolean loggingEnabled()
```
    Specified by:
    
    loggingEnabled in interface StoreBuilder<K>
    
    Returns:
    
    true if the StateStore should have logging enabled
  - name
```
public String name()
```
    Description copied from interface: StoreBuilder
    
    Return the name of this state store builder. This must be a valid Kafka topic name; valid characters are ASCII alphanumerics, '.', '_' and '-'.
    
    Specified by:
    
    name in interface StoreBuilder<K>
    
    Returns:
    
    the name of this state store builder

Class InMemoryTimeOrderedKeyValueBuffer.Builder<K,​V>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

Builder

Method Detail

withCachingEnabled

withCachingDisabled

withLoggingEnabled

withLoggingDisabled

build

logConfig

loggingEnabled

name

Class InMemoryTimeOrderedKeyValueBuffer.Builder<K,V>