Package | Description |
---|---|
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.jobmaster.factories |
Modifier and Type | Class and Description |
---|---|
class |
DefaultJobMasterServiceProcess
Default
JobMasterServiceProcess which is responsible for creating and running a JobMasterService . |
static class |
JobMasterServiceProcess.WaitingForLeadership |
Modifier and Type | Method and Description |
---|---|
static JobMasterServiceProcess |
JobMasterServiceProcess.waitingForLeadership() |
Modifier and Type | Method and Description |
---|---|
JobMasterServiceProcess |
JobMasterServiceProcessFactory.create(UUID leaderSessionId)
Create a new
JobMasterServiceProcess for the given leaderSessionId. |
JobMasterServiceProcess |
DefaultJobMasterServiceProcessFactory.create(UUID leaderSessionId) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.