@Test public void simpleCluster() throws Exception { mCluster = MultiProcessCluster.newBuilder(PortCoordination.MULTI_PROCESS_SIMPLE_CLUSTER) .setClusterName("simpleCluster") .setNumMasters(1) .setNumWorkers(1) .build(); clusterVerification(); }
public static Builder newBuilder(List<ReservedPort> reservedPorts) { return new Builder(reservedPorts); }
MultiProcessCluster { public static Builder newBuilder(List<ReservedPort> reservedPorts) { return new Builder(reservedPorts); } }
MultiProcessCluster { public static Builder newBuilder(List<ReservedPort> reservedPorts) { return new Builder(reservedPorts); } private  MultiProcessCluster(Map<PropertyKey, String> properties,
      Map<Integer, Map<PropertyKey, String>> masterProperties,
      Map<Integer, Map<PropertyKey, String>> workerProperties, int numMasters, int numWorkers,
      String clusterName, boolean noFormat,
      List<PortCoordination.ReservedPort> ports); }
MultiProcessCluster { public static Builder newBuilder(List<ReservedPort> reservedPorts) { return new Builder(reservedPorts); } private  MultiProcessCluster(Map<PropertyKey, String> properties,
      Map<Integer, Map<PropertyKey, String>> masterProperties,
      Map<Integer, Map<PropertyKey, String>> workerProperties, int numMasters, int numWorkers,
      String clusterName, boolean noFormat,
      List<PortCoordination.ReservedPort> ports); synchronized void start(); synchronized int waitForAndKillPrimaryMaster(int timeoutMs); synchronized int getPrimaryMasterIndex(int timeoutMs); synchronized void waitForAllNodesRegistered(int timeoutMs); synchronized DeployMode getDeployMode(); synchronized FileSystemContext getFilesystemContext(); synchronized FileSystem getFileSystemClient(); synchronized MetaMasterClient getMetaMasterClient(); synchronized MetricsMasterClient getMetricsMasterClient(); synchronized JournalMasterClient getJournalMasterClientForMaster(); synchronized Clients getClients(); synchronized void notifySuccess(); synchronized void saveWorkdir(); synchronized void destroy(); synchronized void startMasters(); synchronized void startMaster(int i); synchronized void startWorker(int i); synchronized void stopMasters(); synchronized void stopMaster(int i); synchronized void updateMasterConf(PropertyKey key, @Nullable String value); synchronized void addExternalMasterAddress(MasterNetAddress externalMasterAddress); synchronized void updateDeployMode(DeployMode mode); synchronized void stopWorker(int i); synchronized String getJournalDir(); String getJournalDir(int masterId); synchronized List<MasterNetAddress> getMasterAddresses(); synchronized void stopZk(); synchronized void restartZk(); synchronized void formatJournal(); synchronized MasterInquireClient getMasterInquireClient(); static Builder newBuilder(List<ReservedPort> reservedPorts); }
MultiProcessCluster { public static Builder newBuilder(List<ReservedPort> reservedPorts) { return new Builder(reservedPorts); } private  MultiProcessCluster(Map<PropertyKey, String> properties,
      Map<Integer, Map<PropertyKey, String>> masterProperties,
      Map<Integer, Map<PropertyKey, String>> workerProperties, int numMasters, int numWorkers,
      String clusterName, boolean noFormat,
      List<PortCoordination.ReservedPort> ports); synchronized void start(); synchronized int waitForAndKillPrimaryMaster(int timeoutMs); synchronized int getPrimaryMasterIndex(int timeoutMs); synchronized void waitForAllNodesRegistered(int timeoutMs); synchronized DeployMode getDeployMode(); synchronized FileSystemContext getFilesystemContext(); synchronized FileSystem getFileSystemClient(); synchronized MetaMasterClient getMetaMasterClient(); synchronized MetricsMasterClient getMetricsMasterClient(); synchronized JournalMasterClient getJournalMasterClientForMaster(); synchronized Clients getClients(); synchronized void notifySuccess(); synchronized void saveWorkdir(); synchronized void destroy(); synchronized void startMasters(); synchronized void startMaster(int i); synchronized void startWorker(int i); synchronized void stopMasters(); synchronized void stopMaster(int i); synchronized void updateMasterConf(PropertyKey key, @Nullable String value); synchronized void addExternalMasterAddress(MasterNetAddress externalMasterAddress); synchronized void updateDeployMode(DeployMode mode); synchronized void stopWorker(int i); synchronized String getJournalDir(); String getJournalDir(int masterId); synchronized List<MasterNetAddress> getMasterAddresses(); synchronized void stopZk(); synchronized void restartZk(); synchronized void formatJournal(); synchronized MasterInquireClient getMasterInquireClient(); static Builder newBuilder(List<ReservedPort> reservedPorts); static final String ALLUXIO_USE_FIXED_TEST_PORTS; static final int PORTS_PER_MASTER; static final int PORTS_PER_WORKER; }