Package | Description |
---|---|
org.apache.flink.runtime.minicluster |
Modifier and Type | Class and Description |
---|---|
protected static class |
MiniCluster.CommonRpcServiceFactory
Factory which returns always the common
RpcService . |
protected class |
MiniCluster.DedicatedRpcServiceFactory
Factory which creates and registers new
RpcService . |
Modifier and Type | Method and Description |
---|---|
protected Collection<? extends DispatcherResourceManagerComponent> |
MiniCluster.createDispatcherResourceManagerComponents(Configuration configuration,
MiniCluster.RpcServiceFactory rpcServiceFactory,
HighAvailabilityServices haServices,
BlobServer blobServer,
HeartbeatServices heartbeatServices,
MetricRegistry metricRegistry,
MetricQueryServiceRetriever metricQueryServiceRetriever,
FatalErrorHandler fatalErrorHandler) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.