Package | Description |
---|---|
org.apache.flink.runtime.dispatcher.runner |
Class and Description |
---|
DefaultDispatcherRunnerFactory
DispatcherRunnerFactory implementation which creates DefaultDispatcherRunner
instances. |
DispatcherLeaderProcessFactory
Factory for the
DispatcherLeaderProcess . |
DispatcherLeaderProcessFactoryFactory
Factory for
DispatcherLeaderProcessFactory . |
DispatcherRunner
The
DispatcherRunner encapsulates how a Dispatcher is being executed. |
DispatcherRunnerFactory
Factory interface for the
DispatcherRunner . |
JobDispatcherLeaderProcessFactoryFactory
Factory for the
JobDispatcherLeaderProcessFactory . |
SessionDispatcherLeaderProcess
Process which encapsulates the job recovery logic and life cycle management of a
Dispatcher . |
SessionDispatcherLeaderProcessFactoryFactory
Factory for the
SessionDispatcherLeaderProcessFactory . |
StoppedDispatcherLeaderProcess
DispatcherLeaderProcess implementation which is stopped. |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.