public interface DispatcherFactory
Dispatcher
factory interface.Modifier and Type | Method and Description |
---|---|
Dispatcher |
createDispatcher(RpcService rpcService,
DispatcherId fencingToken,
Collection<JobGraph> recoveredJobs,
PartialDispatcherServicesWithJobGraphStore partialDispatcherServicesWithJobGraphStore)
Create a
Dispatcher . |
default String |
generateEndpointIdWithUUID() |
default String |
getEndpointId() |
Dispatcher createDispatcher(RpcService rpcService, DispatcherId fencingToken, Collection<JobGraph> recoveredJobs, PartialDispatcherServicesWithJobGraphStore partialDispatcherServicesWithJobGraphStore) throws Exception
Dispatcher
.Exception
default String generateEndpointIdWithUUID()
default String getEndpointId()
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.