Package | Description |
---|---|
org.apache.flink.runtime.dispatcher | |
org.apache.flink.runtime.entrypoint |
Constructor and Description |
---|
MiniDispatcher(RpcService rpcService,
String endpointId,
Configuration configuration,
HighAvailabilityServices highAvailabilityServices,
ResourceManagerGateway resourceManagerGateway,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
JobManagerMetricGroup jobManagerMetricGroup,
String metricQueryServicePath,
ArchivedExecutionGraphStore archivedExecutionGraphStore,
Dispatcher.JobManagerRunnerFactory jobManagerRunnerFactory,
FatalErrorHandler fatalErrorHandler,
String restAddress,
HistoryServerArchivist historyServerArchivist,
JobGraph jobGraph,
ClusterEntrypoint.ExecutionMode executionMode) |
Modifier and Type | Method and Description |
---|---|
static ClusterEntrypoint.ExecutionMode |
ClusterEntrypoint.ExecutionMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ClusterEntrypoint.ExecutionMode[] |
ClusterEntrypoint.ExecutionMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.