Package | Description |
---|---|
org.apache.flink.queryablestate.client.proxy | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.query |
Modifier and Type | Method and Description |
---|---|
KvStateLocationOracle |
KvStateClientProxyImpl.getKvStateLocationOracle(JobID jobId) |
Modifier and Type | Method and Description |
---|---|
void |
KvStateClientProxyImpl.updateKvStateLocationOracle(JobID jobId,
KvStateLocationOracle kvStateLocationOracle) |
Modifier and Type | Interface and Description |
---|---|
interface |
JobMasterGateway
JobMaster rpc gateway interface. |
Modifier and Type | Class and Description |
---|---|
class |
JobMaster
JobMaster implementation.
|
Modifier and Type | Method and Description |
---|---|
KvStateLocationOracle |
KvStateClientProxy.getKvStateLocationOracle(JobID jobId)
Retrieves a future containing the currently leading key-value state location oracle.
|
Modifier and Type | Method and Description |
---|---|
void |
KvStateClientProxy.updateKvStateLocationOracle(JobID jobId,
KvStateLocationOracle kvStateLocationOracle)
Updates the active
Job Manager in case
of change. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.