Package | Description |
---|---|
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.taskexecutor.rpc | |
org.apache.flink.runtime.taskmanager |
Modifier and Type | Method and Description |
---|---|
void |
JobMasterGateway.notifyKvStateRegistered(JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
KvStateServerAddress kvStateServerAddress) |
void |
JobMaster.notifyKvStateRegistered(JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
KvStateServerAddress kvStateServerAddress) |
Modifier and Type | Method and Description |
---|---|
KvStateServerAddress |
KvStateMessage.NotifyKvStateRegistered.getKvStateServerAddress()
Returns the server address where to find the KvState instance.
|
KvStateServerAddress |
KvStateLocation.getKvStateServerAddress(int keyGroupIndex)
Returns the registered KvStateServerAddress for the key group index or
null if none is registered yet. |
Modifier and Type | Method and Description |
---|---|
void |
KvStateRegistryGateway.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
KvStateServerAddress kvStateServerAddress)
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.
|
Constructor and Description |
---|
NotifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
KvStateServerAddress kvStateServerAddress)
Notifies the JobManager about a registered
InternalKvState instance. |
Modifier and Type | Method and Description |
---|---|
KvStateServerAddress |
KvStateServer.getAddress()
Returns the address of this server.
|
Modifier and Type | Method and Description |
---|---|
void |
KvStateClient.closeConnection(KvStateServerAddress serverAddress)
Closes the connection to the given server address if it exists.
|
scala.concurrent.Future<byte[]> |
KvStateClient.getKvState(KvStateServerAddress serverAddress,
KvStateID kvStateId,
byte[] serializedKeyAndNamespace)
Returns a future holding the serialized request result.
|
Constructor and Description |
---|
RpcKvStateRegistryListener(KvStateRegistryGateway kvStateRegistryGateway,
KvStateServerAddress kvStateServerAddress) |
Constructor and Description |
---|
ActorGatewayKvStateRegistryListener(ActorGateway jobManager,
KvStateServerAddress kvStateServerAddress) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.