Package | Description |
---|---|
org.apache.flink.runtime.minicluster |
Modifier and Type | Method and Description |
---|---|
protected TaskManagerRunner[] |
MiniCluster.startTaskManagers(Configuration configuration,
HighAvailabilityServices haServices,
MetricRegistry metricRegistry,
int numTaskManagers,
RpcService[] taskManagerRpcServices) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.