public static class InMemoryTimeOrderedKeyValueBuffer.Builder extends java.lang.Object implements StoreBuilder<StateStore>
Constructor and Description |
---|
Builder(java.lang.String storeName) |
Modifier and Type | Method and Description |
---|---|
StateStore |
build()
Build the store as defined by the builder.
|
java.util.Map<java.lang.String,java.lang.String> |
logConfig()
Returns a Map containing any log configs that will be used when creating the changelog for the
StateStore . |
boolean |
loggingEnabled() |
java.lang.String |
name()
Return the name of this state store builder.
|
StoreBuilder<StateStore> |
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<StateStore> |
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<StateStore> |
withLoggingDisabled()
Disable the changelog for store built by this
StoreBuilder . |
StoreBuilder<StateStore> |
withLoggingEnabled(java.util.Map<java.lang.String,java.lang.String> config)
Maintain a changelog for any changes made to the store.
|
public StoreBuilder<StateStore> withCachingEnabled()
cache.max.bytes.buffering
config.
It's currently a no-op.withCachingEnabled
in interface StoreBuilder<StateStore>
public StoreBuilder<StateStore> withCachingDisabled()
cache.max.bytes.buffering
config.
It's currently a no-op.withCachingDisabled
in interface StoreBuilder<StateStore>
public StoreBuilder<StateStore> withLoggingEnabled(java.util.Map<java.lang.String,java.lang.String> config)
StoreBuilder
withLoggingEnabled
in interface StoreBuilder<StateStore>
config
- config applied to the changelog topicpublic StoreBuilder<StateStore> withLoggingDisabled()
StoreBuilder
StoreBuilder
.
This will turn off fault-tolerance for your store.
By default the changelog is enabled.withLoggingDisabled
in interface StoreBuilder<StateStore>
public StateStore build()
StoreBuilder
build
in interface StoreBuilder<StateStore>
StateStore
public java.util.Map<java.lang.String,java.lang.String> logConfig()
StoreBuilder
StateStore
.
Note: any unrecognized configs will be ignored by the Kafka brokers.
logConfig
in interface StoreBuilder<StateStore>
StateStore
If loggingEnabled
returns false, this function will always return an empty mappublic boolean loggingEnabled()
loggingEnabled
in interface StoreBuilder<StateStore>
true
if the StateStore
should have logging enabledpublic java.lang.String name()
StoreBuilder
name
in interface StoreBuilder<StateStore>