Examples of Zone


Examples of voldemort.cluster.Zone

        for(int i = 0; i < 3; i++) {
            LinkedList<Integer> zoneProximityList = Lists.newLinkedList();
            Set<Integer> zoneIds = Sets.newHashSet(0, 1, 2);
            zoneIds.remove(i);
            zoneProximityList.addAll(zoneIds);
            zones.add(new Zone(i, zoneProximityList));
        }

        RoutedStore routedStore = routedStoreFactory.create(new Cluster("test", nodes, zones),
                                                            definition,
                                                            stores,
View Full Code Here

Examples of voldemort.cluster.Zone

        for(int i = 0; i < 3; i++) {
            LinkedList<Integer> zoneProximityList = Lists.newLinkedList();
            Set<Integer> zoneIds = Sets.newHashSet(0, 1, 2);
            zoneIds.remove(i);
            zoneProximityList.addAll(zoneIds);
            zones.add(new Zone(i, zoneProximityList));
        }

        RoutedStore routedStore = routedStoreFactory.create(new Cluster("test", nodes, zones),
                                                            definition,
                                                            stores,
View Full Code Here

Examples of voldemort.cluster.Zone

    public static Cluster getZ0Z2ClusterWithContiguousNodeIDs() {
        // Hand construct zones 0 and 2
        List<Zone> zones = Lists.newArrayList();
        LinkedList<Integer> proximityList0 = Lists.newLinkedList();
        proximityList0.add(2);
        zones.add(new Zone(0, proximityList0));
        LinkedList<Integer> proximityList2 = Lists.newLinkedList();
        proximityList2.add(0);
        zones.add(new Zone(2, proximityList2));

        // Use getZEZCluster because zone 1 does not have any partitions in it!
        Cluster cluster = getZEZCluster();
        List<Node> nodeList = new ArrayList<Node>();
View Full Code Here

Examples of voldemort.cluster.Zone

            zoneIdsSet.add(i);
        }
        Set<Integer> removeSet = new HashSet<Integer>();
        for(int i = 0; i < zoneIds.length; i++) {
            removeSet.add(zoneIds[i]);
            zones.add(new Zone(zoneIds[i], Lists.newLinkedList(Sets.symmetricDifference(zoneIdsSet,
                                                                                        removeSet))));
            removeSet.clear();
        }
        return zones;
    }
View Full Code Here

Examples of voldemort.cluster.Zone

                if(zoneId % numberOfZones != i) {
                    proximityList.add(zoneId % numberOfZones);
                }
                zoneId++;
            }
            zones.add(new Zone(i, proximityList));
        }
        return zones;
    }
View Full Code Here

Examples of voldemort.cluster.Zone

    public void testZoneProximityList() {
        ClusterMapper mapper = new ClusterMapper();
        Cluster cluster = mapper.readCluster(new StringReader(VoldemortTestConstants.getInvalidFourNodeClusterWithZonesXml()));

        Zone expectedZone0 = new Zone(0, new ArrayList<Integer>(Arrays.asList(1, 2)));
        Zone expectedZone1 = new Zone(1, new ArrayList<Integer>(Arrays.asList(0, 2)));
        Zone expectedZone2 = new Zone(2, new ArrayList<Integer>(Arrays.asList(1, 0)));
        assertEquals(cluster.getNumberOfNodes(), 4);
        Zone zone0 = cluster.getZoneById(0);
        Zone zone1 = cluster.getZoneById(1);
        Zone zone2 = cluster.getZoneById(2);

        assertEquals("zone0", expectedZone0, zone0);
        assertEquals("zone1", expectedZone1, zone1);
        assertEquals("zone2", expectedZone2, zone2);
    }
View Full Code Here

Examples of voldemort.cluster.Zone

        // Test proximity size not same
        List<Zone> modifiedZones2 = Lists.newArrayList();
        modifiedZones2.add(zones2.get(0));
        LinkedList<Integer> newProximityList = Lists.newLinkedList(zones2.get(1).getProximityList());
        newProximityList.add(100);
        modifiedZones2.add(new Zone(zones2.get(1).getId(), newProximityList));

        cluster1 = new Cluster("cluster1", new ArrayList<Node>(), zones2);
        cluster2 = new Cluster("cluster2", new ArrayList<Node>(), modifiedZones2);
        assertFalse(cluster1.equals(cluster2));

        // Test proximity list different order
        List<Zone> modifiedZones3 = Lists.newArrayList();
        for(int zoneId = 0; zoneId < 3; zoneId++) {
            LinkedList<Integer> proximityList = Lists.newLinkedList(zones3.get(zoneId)
                                                                          .getProximityList());
            Collections.reverse(proximityList);
            modifiedZones3.add(new Zone(zones3.get(zoneId).getId(), proximityList));
        }

        cluster1 = new Cluster("cluster1", new ArrayList<Node>(), zones3);
        cluster2 = new Cluster("cluster2", new ArrayList<Node>(), modifiedZones3);
        assertFalse(cluster1.equals(cluster2));
View Full Code Here

Examples of voldemort.cluster.Zone

                // important.
                if(proximityList.contains(proximityZoneId) == false) {
                    proximityList.add(proximityZoneId);
                }
            }
        return new Zone(zoneId, proximityList);
    }
View Full Code Here

Examples of voldemort.cluster.Zone

                continue;
            }
            List<Integer> proximityList = intermediateCluster.getZoneById(zoneId)
                                                             .getProximityList();
            proximityList.remove(new Integer(dropZoneId));
            zones.add(new Zone(zoneId, proximityList));
        }

        return new Cluster(intermediateCluster.getName(),
                           Utils.asSortedList(survivingNodes),
                           Utils.asSortedList(zones));
View Full Code Here

Examples of worldManager.gameEngine.Zone

            pstmt = connection.prepareStatement(query);
            pstmt.setInt(1, env_id);
            ResultSet rs = pstmt.executeQuery();

            while (rs.next()) {
                Zone zone = new Zone(rs.getInt("zone_id"));
                zone.setOrder(rs.getInt("order"));
                zone.setEnvID(rs.getInt("env_id"));
                zone.setRow(rs.getInt("row"));
                zone.setColumn(rs.getInt("column"));
                zone.setManipulationID(rs.getString("manipulation_id"));
                zone.setCurrentTimeStep(rs.getInt("current_time_step"));
                zone.setMaxBiomass(rs.getFloat("max_biomass"));
                zone.setPrevBiomass(rs.getFloat("prev_biomass"));

                returnZoneList.add(zone);
            }

            rs.close();
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.