Package | Description |
---|---|
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.taskmanager |
Modifier and Type | Method and Description |
---|---|
KvStateID |
KvStateMessage.NotifyKvStateRegistered.getKvStateId()
Returns the ID of the registered KvState instance.
|
KvStateID |
KvStateLocation.getKvStateID(int keyGroupIndex)
Returns the registered KvStateID for the key group index or
null if none is registered yet. |
KvStateID |
KvStateRegistry.registerKvState(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvState<?> kvState)
Registers the KvState instance and returns the assigned ID.
|
Modifier and Type | Method and Description |
---|---|
KvState<?> |
KvStateRegistry.getKvState(KvStateID kvStateId)
Returns the KvState instance identified by the given KvStateID or
null if none is registered. |
void |
KvStateRegistryListener.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId)
Notifies the listener about a registered KvState instance.
|
void |
KvStateLocationRegistry.notifyKvStateRegistered(JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
KvStateServerAddress kvStateServerAddress)
Notifies the registry about a registered KvState instance.
|
void |
KvStateRegistry.unregisterKvState(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId)
Unregisters the KvState instance identified by the given KvStateID.
|
Constructor and Description |
---|
NotifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
KvStateServerAddress kvStateServerAddress)
Notifies the JobManager about a registered
KvState instance. |
Modifier and Type | Method and Description |
---|---|
scala.concurrent.Future<byte[]> |
KvStateClient.getKvState(KvStateServerAddress serverAddress,
KvStateID kvStateId,
byte[] serializedKeyAndNamespace)
Returns a future holding the serialized request result.
|
Constructor and Description |
---|
UnknownKvStateID(KvStateID kvStateId) |
Modifier and Type | Method and Description |
---|---|
KvStateID |
KvStateRequest.getKvStateId()
Returns the ID of the requested KvState instance.
|
Modifier and Type | Method and Description |
---|---|
static io.netty.buffer.ByteBuf |
KvStateRequestSerializer.serializeKvStateRequest(io.netty.buffer.ByteBufAllocator alloc,
long requestId,
KvStateID kvStateId,
byte[] serializedKeyAndNamespace)
Allocates a buffer and serializes the KvState request into it.
|
Modifier and Type | Method and Description |
---|---|
void |
ActorGatewayKvStateRegistryListener.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.