Package org.apache.kafka.streams.state

Class DslKeyValueParams

java.lang.Object

org.apache.kafka.streams.state.DslKeyValueParams

public class DslKeyValueParams
extends Object

DslKeyValueParams is a wrapper class for all parameters that function as inputs to DslStoreSuppliers.keyValueStore(DslKeyValueParams).

Constructor Summary

Constructors

Constructor	Description
DslKeyValueParams(String name, boolean isTimestamped)	Deprecated. Since 4.3.
DslKeyValueParams(String name, DslStoreFormat dslStoreFormat)

Method Summary

Modifier and Type	Method	Description
DslStoreFormat	dslStoreFormat()	Returns the store format for this key-value store.
boolean	equals(Object o)
int	hashCode()
boolean	isTimestamped()	Deprecated. Since 4.3.
String	name()
String	toString()

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

DslKeyValueParams

@Deprecated
public DslKeyValueParams(String name,
 boolean isTimestamped)

Deprecated.

Since 4.3. Use DslKeyValueParams(String, DslStoreFormat) instead.

Parameters:

name - the name of the store (cannot be null)

isTimestamped - whether the returned stores should be timestamped, see (TimestampedKeyValueStore

DslKeyValueParams

public DslKeyValueParams(String name,
 DslStoreFormat dslStoreFormat)

Parameters:

name - the name of the store (cannot be null)

dslStoreFormat - the format of the state store, see (DslStoreFormat

Method Details

name

public String name()

isTimestamped

@Deprecated
public boolean isTimestamped()

Deprecated.

Since 4.3. Use dslStoreFormat() instead to check the store format.

Returns:

true if the store format is DslStoreFormat.TIMESTAMPED, false otherwise

dslStoreFormat

public DslStoreFormat dslStoreFormat()

Returns the store format for this key-value store.

Returns:

the DslStoreFormat specifying whether to use plain, timestamped, or headers-aware stores

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object