Package org.apache.flink.table.runtime.sequencedmultisetstate

Class SequencedMultiSetStateConfig

java.lang.Object

org.apache.flink.table.runtime.sequencedmultisetstate.SequencedMultiSetStateConfig

All Implemented Interfaces:

Serializable

public class SequencedMultiSetStateConfig
extends Object
implements Serializable

Configuration for SequencedMultiSetState.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
SequencedMultiSetStateConfig(SequencedMultiSetState.Strategy strategy, Long adaptiveHighThresholdOverride, Long adaptiveLowThresholdOverride, org.apache.flink.api.common.state.StateTtlConfig ttlConfig, org.apache.flink.streaming.api.TimeDomain ttlTimeDomain)
SequencedMultiSetStateConfig(SequencedMultiSetState.Strategy strategy, Long adaptiveHighThresholdOverride, Long adaptiveLowThresholdOverride, org.apache.flink.api.common.state.StateTtlConfig ttlConfig, TimeSelector ttlTimeSelector)

Method Summary

Modifier and Type	Method	Description
static SequencedMultiSetStateConfig	adaptive(org.apache.flink.streaming.api.TimeDomain ttlTimeDomain, Long adaptiveHighThresholdOverride, Long adaptiveLowThresholdOverride, org.apache.flink.api.common.state.StateTtlConfig ttl)
static SequencedMultiSetStateConfig	defaults(org.apache.flink.streaming.api.TimeDomain ttlTimeDomain, org.apache.flink.api.common.state.StateTtlConfig ttlConfig)
static SequencedMultiSetStateConfig	forMap(org.apache.flink.streaming.api.TimeDomain ttlTimeDomain, org.apache.flink.api.common.state.StateTtlConfig ttlConfig)
static SequencedMultiSetStateConfig	forValue(org.apache.flink.streaming.api.TimeDomain ttlTimeDomain, org.apache.flink.api.common.state.StateTtlConfig ttl)
Optional<Long>	getAdaptiveHighThresholdOverride()
Optional<Long>	getAdaptiveLowThresholdOverride()
SequencedMultiSetState.Strategy	getStrategy()
TimeSelector	getTimeSelector()
org.apache.flink.api.common.state.StateTtlConfig	getTtlConfig()

Methods inherited from class java.lang.Object

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

Constructor Detail

SequencedMultiSetStateConfig

public SequencedMultiSetStateConfig(SequencedMultiSetState.Strategy strategy,
                                    @Nullable
                                    Long adaptiveHighThresholdOverride,
                                    @Nullable
                                    Long adaptiveLowThresholdOverride,
                                    org.apache.flink.api.common.state.StateTtlConfig ttlConfig,
                                    org.apache.flink.streaming.api.TimeDomain ttlTimeDomain)

SequencedMultiSetStateConfig

public SequencedMultiSetStateConfig(SequencedMultiSetState.Strategy strategy,
                                    @Nullable
                                    Long adaptiveHighThresholdOverride,
                                    @Nullable
                                    Long adaptiveLowThresholdOverride,
                                    org.apache.flink.api.common.state.StateTtlConfig ttlConfig,
                                    TimeSelector ttlTimeSelector)

Method Detail

defaults

public static SequencedMultiSetStateConfig defaults(org.apache.flink.streaming.api.TimeDomain ttlTimeDomain,
                                                    org.apache.flink.api.common.state.StateTtlConfig ttlConfig)

forMap

public static SequencedMultiSetStateConfig forMap(org.apache.flink.streaming.api.TimeDomain ttlTimeDomain,
                                                  org.apache.flink.api.common.state.StateTtlConfig ttlConfig)

forValue

public static SequencedMultiSetStateConfig forValue(org.apache.flink.streaming.api.TimeDomain ttlTimeDomain,
                                                    org.apache.flink.api.common.state.StateTtlConfig ttl)

adaptive

public static SequencedMultiSetStateConfig adaptive(org.apache.flink.streaming.api.TimeDomain ttlTimeDomain,
                                                    @Nullable
                                                    Long adaptiveHighThresholdOverride,
                                                    @Nullable
                                                    Long adaptiveLowThresholdOverride,
                                                    org.apache.flink.api.common.state.StateTtlConfig ttl)

getTimeSelector

public TimeSelector getTimeSelector()

getStrategy

public SequencedMultiSetState.Strategy getStrategy()

getAdaptiveHighThresholdOverride

public Optional<Long> getAdaptiveHighThresholdOverride()

getAdaptiveLowThresholdOverride

public Optional<Long> getAdaptiveLowThresholdOverride()

getTtlConfig

public org.apache.flink.api.common.state.StateTtlConfig getTtlConfig()