Package | Description |
---|---|
org.apache.flink.runtime.scheduler | |
org.apache.flink.runtime.scheduler.adaptive |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerBase.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
InetSocketAddress kvStateServerAddress) |
void |
KvStateHandler.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
InetSocketAddress kvStateServerAddress) |
void |
SchedulerNG.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
InetSocketAddress kvStateServerAddress) |
void |
SchedulerBase.notifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName) |
void |
KvStateHandler.notifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName) |
void |
SchedulerNG.notifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName) |
KvStateLocation |
SchedulerBase.requestKvStateLocation(JobID jobId,
String registrationName) |
KvStateLocation |
KvStateHandler.requestKvStateLocation(JobID jobId,
String registrationName) |
KvStateLocation |
SchedulerNG.requestKvStateLocation(JobID jobId,
String registrationName) |
Modifier and Type | Method and Description |
---|---|
void |
AdaptiveScheduler.notifyKvStateRegistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName,
KvStateID kvStateId,
InetSocketAddress kvStateServerAddress) |
void |
AdaptiveScheduler.notifyKvStateUnregistered(JobID jobId,
JobVertexID jobVertexId,
KeyGroupRange keyGroupRange,
String registrationName) |
KvStateLocation |
AdaptiveScheduler.requestKvStateLocation(JobID jobId,
String registrationName) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.