@Test public void testThatGroupsAreCountedInWhenComputingSplitBits() { StorDistributormanagerConfig.Builder builder = new StorDistributormanagerConfig.Builder(); ContentCluster cluster = parseCluster("<cluster id=\"storage\">\n" + " <documents/>" + " <tuning>" + " <distribution type=\"legacy\"/>" + " </tuning>\n" + " <group>" + " <node distribution-key=\"0\" hostalias=\"mockhost\"/>" + " <node distribution-key=\"1\" hostalias=\"mockhost\"/>" + " </group>" + "</cluster>"); cluster.getConfig(builder); StorDistributormanagerConfig conf = new StorDistributormanagerConfig(builder); assertEquals(1024, conf.splitcount()); assertEquals(512, conf.joincount()); assertEquals(33544432, conf.splitsize()); assertEquals(16000000, conf.joinsize()); assertEquals(8, conf.minsplitcount()); assertTrue(conf.inlinebucketsplitting()); cluster = parseCluster("<cluster id=\"storage\">\n" + " <redundancy>2</redundancy>" + " <documents/>" + " <tuning>" + " <distribution type=\"legacy\"/>" + " </tuning>\n" + " <group>" + " <distribution partitions=\"1|*\"/>" + " <group name=\"a\" distribution-key=\"0\">" + " <node distribution-key=\"0\" hostalias=\"mockhost\"/>" + " </group>" + " <group name=\"b\" distribution-key=\"1\">" + " <node distribution-key=\"1\" hostalias=\"mockhost\"/>" + " </group>" + " </group>" + "</cluster>"); cluster.getConfig(builder); conf = new StorDistributormanagerConfig(builder); assertEquals(1024, conf.splitcount()); assertEquals(512, conf.joincount()); assertEquals(33544432, conf.splitsize()); assertEquals(16000000, conf.joinsize()); assertEquals(1, conf.minsplitcount()); assertTrue(conf.inlinebucketsplitting()); }
@Override public void getConfig(StorServerConfig.Builder builder) { super.getConfig(builder); provider.getConfig(builder); }
Distributor extends ContentNode { @Override public void getConfig(StorServerConfig.Builder builder) { super.getConfig(builder); provider.getConfig(builder); } }
Distributor extends ContentNode { @Override public void getConfig(StorServerConfig.Builder builder) { super.getConfig(builder); provider.getConfig(builder); } Distributor(ModelContext.Properties properties, DistributorCluster parent, int distributionKey, Integer distributorBasePort, PersistenceEngine provider); }
Distributor extends ContentNode { @Override public void getConfig(StorServerConfig.Builder builder) { super.getConfig(builder); provider.getConfig(builder); } Distributor(ModelContext.Properties properties, DistributorCluster parent, int distributionKey, Integer distributorBasePort, PersistenceEngine provider); @Override void getConfig(StorServerConfig.Builder builder); @Override void getConfig(StorCommunicationmanagerConfig.Builder builder); @Override String getStartupCommand(); }
Distributor extends ContentNode { @Override public void getConfig(StorServerConfig.Builder builder) { super.getConfig(builder); provider.getConfig(builder); } Distributor(ModelContext.Properties properties, DistributorCluster parent, int distributionKey, Integer distributorBasePort, PersistenceEngine provider); @Override void getConfig(StorServerConfig.Builder builder); @Override void getConfig(StorCommunicationmanagerConfig.Builder builder); @Override String getStartupCommand();  }