public class KvStateService extends Object
TaskExecutor
instance. This service can
create the kvState registration for a single task.Constructor and Description |
---|
KvStateService(KvStateRegistry kvStateRegistry,
KvStateServer kvStateServer,
KvStateClientProxy kvStateClientProxy) |
Modifier and Type | Method and Description |
---|---|
TaskKvStateRegistry |
createKvStateTaskRegistry(JobID jobId,
JobVertexID jobVertexId) |
static KvStateService |
fromConfiguration(TaskManagerServicesConfiguration taskManagerServicesConfiguration)
Creates and returns the KvState service.
|
KvStateClientProxy |
getKvStateClientProxy() |
KvStateRegistry |
getKvStateRegistry() |
KvStateServer |
getKvStateServer() |
boolean |
isShutdown() |
void |
shutdown() |
void |
start() |
public KvStateService(KvStateRegistry kvStateRegistry, KvStateServer kvStateServer, KvStateClientProxy kvStateClientProxy)
public KvStateRegistry getKvStateRegistry()
public KvStateServer getKvStateServer()
public KvStateClientProxy getKvStateClientProxy()
public TaskKvStateRegistry createKvStateTaskRegistry(JobID jobId, JobVertexID jobVertexId)
public void start()
public void shutdown()
public boolean isShutdown()
public static KvStateService fromConfiguration(TaskManagerServicesConfiguration taskManagerServicesConfiguration)
taskManagerServicesConfiguration
- task manager configurationCopyright © 2014–2020 The Apache Software Foundation. All rights reserved.