Package | Description |
---|---|
org.apache.flink.contrib.streaming.state | |
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 |
This package contains all KvState query related classes.
|
org.apache.flink.runtime.query.netty |
This package contains all Netty-based client/server classes used to query
KvState instances.
|
org.apache.flink.runtime.query.netty.message | |
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 |
---|
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 |
---|
KvStateRegistry
A registry for
InternalKvState instances per task manager. |
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Class and Description |
---|
KvStateID
Identifier for
InternalKvState instances. |
KvStateLocation
Location information for all key groups of a
InternalKvState instance. |
KvStateServerAddress
The (host, port)-address of a
KvStateServer . |
Class and Description |
---|
KvStateID
Identifier for
InternalKvState instances. |
KvStateLocation
Location information for all key groups of a
InternalKvState instance. |
KvStateLocationLookupService
KvStateLocation lookup service. |
KvStateMessage
Actor messages for
InternalKvState lookup and registration. |
KvStateRegistryListener
A listener for a
KvStateRegistry . |
KvStateServerAddress
The (host, port)-address of a
KvStateServer . |
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Class and Description |
---|
KvStateID
Identifier for
InternalKvState instances. |
KvStateRegistry
A registry for
InternalKvState instances per task manager. |
KvStateServerAddress
The (host, port)-address of a
KvStateServer . |
Class and Description |
---|
KvStateID
Identifier for
InternalKvState instances. |
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 |
---|
KvStateID
Identifier for
InternalKvState instances. |
KvStateRegistryGateway |
KvStateRegistryListener
A listener for a
KvStateRegistry . |
KvStateServerAddress
The (host, port)-address of a
KvStateServer . |
Class and Description |
---|
KvStateID
Identifier for
InternalKvState instances. |
KvStateRegistryListener
A listener for a
KvStateRegistry . |
KvStateServerAddress
The (host, port)-address of a
KvStateServer . |
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.