See: Description
| Interface | Description |
|---|---|
| KvStateLocationLookupService |
KvStateLocation lookup service. |
| KvStateMessage |
Actor messages for
InternalKvState lookup and registration. |
| KvStateRegistryGateway | |
| KvStateRegistryListener |
A listener for a
KvStateRegistry. |
| Class | Description |
|---|---|
| KvStateID |
Identifier for
InternalKvState instances. |
| KvStateLocation |
Location information for all key groups of a
InternalKvState instance. |
| KvStateLocationRegistry |
Simple registry, which maps
InternalKvState registration notifications to
KvStateLocation instances. |
| KvStateMessage.LookupKvStateLocation | |
| KvStateMessage.NotifyKvStateRegistered | |
| KvStateMessage.NotifyKvStateUnregistered | |
| KvStateRegistry |
A registry for
InternalKvState instances per task manager. |
| KvStateServerAddress |
The (host, port)-address of a
KvStateServer. |
| QueryableStateClient |
Client for queryable state.
|
| TaskKvStateRegistry |
A helper for KvState registrations of a single task.
|
| Exception | Description |
|---|---|
| UnknownKvStateLocation |
Thrown if there is no
KvStateLocation found for the requested
registration name. |
State backends register queryable state instances at the KvStateRegistry.
There is one registry per TaskManager. Registered KvState instances are
reported to the JobManager, where they are aggregated at the KvStateLocationRegistry.
Instances of KvStateLocation contain
all information needed for a client to query a KvState instance.
See also:
QueryableStateClient is used
to query KvState instances. The client takes care of KvStateLocation lookup and caching. Queries
are then dispatched via the network client.
The JobManager is queried for KvStateLocation
instances via the KvStateLocationLookupService.
The client caches resolved locations and dispatches queries directly to the
TaskManager.
After the location has been resolved, the TaskManager is queried via the
KvStateClient.
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.