org.apache.flink.runtime.scheduler

Class KvStateHandler

java.lang.Object

org.apache.flink.runtime.scheduler.KvStateHandler

public class KvStateHandler
extends Object

Handler for common queryable state logic.

Constructor Summary

Constructors

Constructor and Description
KvStateHandler(ExecutionGraph executionGraph)

Method Summary

Modifier and Type	Method and Description
void	notifyKvStateRegistered(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName, KvStateID kvStateId, InetSocketAddress kvStateServerAddress)
void	notifyKvStateUnregistered(JobID jobId, JobVertexID jobVertexId, KeyGroupRange keyGroupRange, String registrationName)
KvStateLocation	requestKvStateLocation(JobID jobId, String registrationName)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KvStateHandler

public KvStateHandler(ExecutionGraph executionGraph)

Method Detail

requestKvStateLocation

public KvStateLocation requestKvStateLocation(JobID jobId,
                                              String registrationName)
                                       throws UnknownKvStateLocation,
                                              FlinkJobNotFoundException

Throws:

UnknownKvStateLocation

FlinkJobNotFoundException

notifyKvStateRegistered

public void notifyKvStateRegistered(JobID jobId,
                                    JobVertexID jobVertexId,
                                    KeyGroupRange keyGroupRange,
                                    String registrationName,
                                    KvStateID kvStateId,
                                    InetSocketAddress kvStateServerAddress)
                             throws FlinkJobNotFoundException

Throws:

FlinkJobNotFoundException

notifyKvStateUnregistered

public void notifyKvStateUnregistered(JobID jobId,
                                      JobVertexID jobVertexId,
                                      KeyGroupRange keyGroupRange,
                                      String registrationName)
                               throws FlinkJobNotFoundException

Throws:

FlinkJobNotFoundException