org.apache.flink.runtime.taskmanager

Class ActorGatewayKvStateLocationOracle

java.lang.Object

org.apache.flink.runtime.taskmanager.ActorGatewayKvStateLocationOracle

All Implemented Interfaces:

KvStateLocationOracle

public class ActorGatewayKvStateLocationOracle
extends Object
implements KvStateLocationOracle

KvStateLocationOracle implementation for ActorGateway.

Constructor Summary

Constructors

Constructor and Description
ActorGatewayKvStateLocationOracle(ActorGateway jobManagerActorGateway, Time timeout)

Method Summary

Modifier and Type	Method and Description
CompletableFuture<KvStateLocation>	requestKvStateLocation(JobID jobId, String registrationName) Requests a KvStateLocation for the specified InternalKvState registration name.

Methods inherited from class java.lang.Object

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

Constructor Detail

ActorGatewayKvStateLocationOracle

public ActorGatewayKvStateLocationOracle(ActorGateway jobManagerActorGateway,
                                         Time timeout)

Method Detail

requestKvStateLocation

public CompletableFuture<KvStateLocation> requestKvStateLocation(JobID jobId,
                                                                 String registrationName)

Description copied from interface: KvStateLocationOracle

Requests a KvStateLocation for the specified InternalKvState registration name.

Specified by:

requestKvStateLocation in interface KvStateLocationOracle

Parameters:

jobId - identifying the job for which to request the KvStateLocation

registrationName - Name under which the KvState has been registered.

Returns:

Future of the requested InternalKvState location