org.apache.flink.runtime.query

Class KvStateMessage.LookupKvStateLocation

java.lang.Object

org.apache.flink.runtime.query.KvStateMessage.LookupKvStateLocation

All Implemented Interfaces:

Serializable, KvStateMessage

Enclosing interface:

KvStateMessage

public static class KvStateMessage.LookupKvStateLocation
extends Object
implements KvStateMessage

Actor message for looking up KvStateLocation.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.query.KvStateMessage

KvStateMessage.LookupKvStateLocation, KvStateMessage.NotifyKvStateRegistered, KvStateMessage.NotifyKvStateUnregistered

Constructor Summary

Constructors

Constructor and Description
LookupKvStateLocation(JobID jobId, String registrationName) Requests a KvStateLocation for the specified JobID and InternalKvState registration name.

Method Summary

Modifier and Type	Method and Description
JobID	getJobId() Returns the JobID the KvState instance belongs to.
String	getRegistrationName() Returns the name under which the KvState has been registered.
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

LookupKvStateLocation

public LookupKvStateLocation(JobID jobId,
                             String registrationName)

Requests a KvStateLocation for the specified JobID and InternalKvState registration name.

Parameters:

jobId - JobID the KvState instance belongs to

registrationName - Name under which the KvState has been registered

Method Detail

getJobId

public JobID getJobId()

Returns the JobID the KvState instance belongs to.

Returns:

JobID the KvState instance belongs to

getRegistrationName

public String getRegistrationName()

Returns the name under which the KvState has been registered.

Returns:

Name under which the KvState has been registered

toString

public String toString()

Overrides:

toString in class Object