Package org.apache.kafka.streams.state

Class DslSessionParams

java.lang.Object

org.apache.kafka.streams.state.DslSessionParams

public class DslSessionParams
extends Object

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

Constructor Summary

Constructors

Constructor	Description
DslSessionParams(String name, Duration retentionPeriod, EmitStrategy emitStrategy)

Method Summary

Modifier and Type	Method	Description
EmitStrategy	emitStrategy()
boolean	equals(Object o)
int	hashCode()
String	name()
Duration	retentionPeriod()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

DslSessionParams

public DslSessionParams(String name,
 Duration retentionPeriod,
 EmitStrategy emitStrategy)

Parameters:

name - name of the store (cannot be null)

retentionPeriod - length of time to retain data in the store (cannot be negative) (note that the retention period must be at least as long enough to contain the inactivity gap of the session and the entire grace period.)

emitStrategy - defines how to emit results

Method Details

name

public String name()

retentionPeriod

public Duration retentionPeriod()

emitStrategy

public EmitStrategy emitStrategy()

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