Package | Description |
---|---|
org.apache.flink.statefun.flink.core.httpfn | |
org.apache.flink.statefun.flink.datastream | |
org.apache.flink.statefun.sdk.state |
Modifier and Type | Method and Description |
---|---|
Expiration |
StateSpec.ttlExpiration() |
Constructor and Description |
---|
StateSpec(java.lang.String name,
Expiration ttlExpiration) |
Modifier and Type | Method and Description |
---|---|
RequestReplyFunctionBuilder |
RequestReplyFunctionBuilder.withExpiringState(java.lang.String name,
Expiration ttlExpiration)
Declares a remote function state, with expiration.
|
Modifier and Type | Method and Description |
---|---|
Expiration |
PersistedTable.expiration() |
Expiration |
PersistedValue.expiration() |
Expiration |
PersistedAppendingBuffer.expiration() |
static Expiration |
Expiration.expireAfter(java.time.Duration duration,
Expiration.Mode mode) |
static Expiration |
Expiration.expireAfterReadingOrWriting(java.time.Duration duration)
Returns an Expiration configuration that would expire a @duration after the last write or read.
|
static Expiration |
Expiration.expireAfterWriting(java.time.Duration duration)
Returns an Expiration configuration that would expire a @duration after the last write.
|
static Expiration |
Expiration.none() |
Modifier and Type | Method and Description |
---|---|
static <E> PersistedAppendingBuffer<E> |
PersistedAppendingBuffer.of(java.lang.String name,
java.lang.Class<E> elementType,
Expiration expiration)
Creates a
PersistedAppendingBuffer instance that may be used to access persisted state
managed by the system. |
static <K,V> PersistedTable<K,V> |
PersistedTable.of(java.lang.String name,
java.lang.Class<K> keyType,
java.lang.Class<V> valueType,
Expiration expiration)
Creates a
PersistedTable instance that may be used to access persisted state managed by
the system. |
static <T> PersistedValue<T> |
PersistedValue.of(java.lang.String name,
java.lang.Class<T> type,
Expiration expiration)
Creates a
PersistedValue instance that may be used to access persisted state managed by
the system. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.