Package | Description |
---|---|
org.apache.flink.statefun.e2e.smoke.embedded | |
org.apache.flink.statefun.flink.core.state | |
org.apache.flink.statefun.sdk.state |
Class and Description |
---|
PersistedValue
A
PersistedValue is a value registered within StatefulFunction s and is persisted
and maintained by the system for fault-tolerance. |
Class and Description |
---|
Accessor |
AppendingBufferAccessor |
PersistedAppendingBuffer
A
PersistedAppendingBuffer is an append-only buffer registered within StatefulFunction s and is persisted and maintained by the system for fault-tolerance. |
PersistedTable
A
PersistedTable is a table (collection of keys and values) registered within StatefulFunction s and is persisted and maintained by the system for fault-tolerance. |
PersistedValue
A
PersistedValue is a value registered within StatefulFunction s and is persisted
and maintained by the system for fault-tolerance. |
RemotePersistedValue |
StateBinder |
TableAccessor |
Class and Description |
---|
Accessor |
AppendingBufferAccessor |
Expiration
State Expiration Configuration
|
Expiration.Mode |
PersistedAppendingBuffer
A
PersistedAppendingBuffer is an append-only buffer registered within StatefulFunction s and is persisted and maintained by the system for fault-tolerance. |
PersistedStateRegistry
A
PersistedStateRegistry can be used to register persisted state, such as a PersistedValue or PersistedTable , etc. |
PersistedTable
A
PersistedTable is a table (collection of keys and values) registered within StatefulFunction s and is persisted and maintained by the system for fault-tolerance. |
PersistedValue
A
PersistedValue is a value registered within StatefulFunction s and is persisted
and maintained by the system for fault-tolerance. |
RemotePersistedValue |
StateBinder |
TableAccessor |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.