public class MiniSparkOnYARNCluster
extends org.apache.hadoop.yarn.server.MiniYARNCluster
org.apache.hadoop.yarn.server.MiniYARNCluster.CustomNodeManager
Constructor and Description |
---|
MiniSparkOnYARNCluster(String testName) |
MiniSparkOnYARNCluster(String testName,
int numResourceManagers,
int numNodeManagers) |
MiniSparkOnYARNCluster(String testName,
int numResourceManagers,
int numNodeManagers,
int numLocalDirs,
int numLogDirs) |
createResourceManager, getActiveRMIndex, getApplicationHistoryServer, getHostname, getNodeManager, getNumOfResourceManager, getResourceManager, getResourceManager, getTestWorkDir, restartResourceManager, serviceInit, serviceStart, stopResourceManager, waitForNodeManagersToConnect
addIfService, addService, getServices, removeService, serviceStop
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public MiniSparkOnYARNCluster(String testName)
public MiniSparkOnYARNCluster(String testName, int numResourceManagers, int numNodeManagers)
public MiniSparkOnYARNCluster(String testName, int numResourceManagers, int numNodeManagers, int numLocalDirs, int numLogDirs)
Copyright © 2022 The Apache Software Foundation. All rights reserved.