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.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.filesystem.async | |
org.apache.flink.runtime.state.heap | |
org.apache.flink.runtime.state.heap.async | |
org.apache.flink.runtime.state.memory | |
org.apache.flink.runtime.state.memory.async | |
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
KvState registration notifications to
KvStateLocation instances. |
Class and Description |
---|
KvStateRegistry
A registry for
KvState instances per task manager. |
TaskKvStateRegistry
A helper for KvState registrations of a single task.
|
Class and Description |
---|
KvStateID
Identifier for
KvState instances. |
KvStateLocation
Location information for all key groups of a
KvState instance. |
KvStateLocationLookupService
KvStateLocation lookup service. |
KvStateMessage
Actor messages for
KvState 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
KvState instances. |
KvStateRegistry
A registry for
KvState instances per task manager. |
KvStateServerAddress
The (host, port)-address of a
KvStateServer . |
Class and Description |
---|
KvStateID
Identifier for
KvState 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 |
---|
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
KvState 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–2017 The Apache Software Foundation. All rights reserved.