Package | Description |
---|---|
org.apache.flink.statefun.sdk.state |
Modifier and Type | Method and Description |
---|---|
Expiration |
PersistedValue.expiration() |
Expiration |
RemotePersistedValue.expiration() |
Expiration |
PersistedTable.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. |
static RemotePersistedValue |
RemotePersistedValue.of(java.lang.String stateName,
TypeName typeName,
Expiration expiration) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.