Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
org.apache.flink.queryablestate.client.proxy | |
org.apache.flink.queryablestate.server | |
org.apache.flink.runtime.execution | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.io.network | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.query | |
org.apache.flink.runtime.state | |
org.apache.flink.runtime.state.filesystem | |
org.apache.flink.runtime.state.heap |
This package contains the classes for key/value state backends that store the state
on the JVM heap as objects.
|
org.apache.flink.runtime.state.memory | |
org.apache.flink.runtime.taskexecutor.rpc | |
org.apache.flink.runtime.taskmanager |
Class and Description |
---|
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Class and Description |
---|
KvStateClientProxy
An interface for the Queryable State Client Proxy running on each Task Manager in the cluster.
|
KvStateServer
An interface for the Queryable State Server running on each Task Manager in the cluster.
|
Class and Description |
---|
KvStateRegistry
A registry for
InternalKvState instances per task manager. |
KvStateServer
An interface for the Queryable State Server running on each Task Manager in the cluster.
|
Class and Description |
---|
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Class and Description |
---|
KvStateLocationRegistry
Simple registry, which maps
InternalKvState registration notifications to
KvStateLocation instances. |
Class and Description |
---|
KvStateClientProxy
An interface for the Queryable State Client Proxy running on each Task Manager in the cluster.
|
KvStateRegistry
A registry for
InternalKvState instances per task manager. |
KvStateServer
An interface for the Queryable State Server running on each Task Manager in the cluster.
|
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Class and Description |
---|
KvStateLocation
Location information for all key groups of a
InternalKvState instance. |
Class and Description |
---|
KvStateClientProxy
An interface for the Queryable State Client Proxy running on each Task Manager in the cluster.
|
KvStateEntry
An entry holding the
InternalKvState along with its KvStateInfo . |
KvStateInfo
Metadata about a
InternalKvState . |
KvStateLocation
Location information for all key groups of a
InternalKvState instance. |
KvStateMessage
Actor messages for
InternalKvState lookup and registration. |
KvStateRegistry
A registry for
InternalKvState instances per task manager. |
KvStateRegistryListener
A listener for a
KvStateRegistry . |
KvStateServer
An interface for the Queryable State Server running on each Task Manager in the cluster.
|
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Class and Description |
---|
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Class and Description |
---|
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Class and Description |
---|
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Class and Description |
---|
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Class and Description |
---|
KvStateRegistryListener
A listener for a
KvStateRegistry . |
Class and Description |
---|
KvStateLocation
Location information for all key groups of a
InternalKvState instance. |
KvStateRegistryListener
A listener for a
KvStateRegistry . |
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.