Examples of WorkerNode

Examples of io.fabric8.partition.WorkerNode

95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
            distribution.put(path, item);
        }
        //Second pass - assignment
        for (String member : members) {
            try {
                WorkerNode node = mapper.readValue(curator.get().getData().forPath(member), WorkerNode.class);
                Collection<String> assignedItems = distribution.get(member);

                if (assignedItems != null) {
                    node.setItems(assignedItems.toArray(new String[assignedItems.size()]));
                } else {
                    node.setItems(new String[0]);
                }

                String targetPath = ZkPath.TASK_MEMBER_PARTITIONS.getPath(node.getContainer(), context.getId());
                curator.get().setData().forPath(targetPath, mapper.writeValueAsBytes(node));
            } catch (Exception ex) {
                LOGGER.error("Error while assigning work", ex);
            }
        }
View Full Code Here

Examples of io.fabric8.partition.WorkerNode

69
70
71
72
73
74
75
76
            throw FabricException.launderThrowable(e);
        }
    }

    WorkerNode createNode() {
        WorkerNode state = new WorkerNode(context.getId());
        return state;
    }
View Full Code Here

Examples of io.fabric8.partition.WorkerNode

78
79
80
81
82
83
84
85
86
87
88
89
90
91
    @Override
    public void groupEvent(Group<WorkerNode> group, GroupEvent event) {
        switch (event) {
            case CONNECTED:
            case CHANGED:
                WorkerNode state = createNode();
                if (group.isMaster()) {
                    repository.start();
                    state.setServices(new String[] {context.getId()});
                    group.update(state);
                    partitionUpdated();
                } else {
                    group.update(state);
                    repository.stop();
View Full Code Here

Examples of io.fabric8.partition.WorkerNode

90
91
92
93
94
95
96
97
98
99
100
    }

    @Override
    public synchronized void nodeChanged() throws Exception {
        LOGGER.info("Task Handler for {} detected change.", context.getId());
        WorkerNode node = readWorkerNode();
        Set<WorkItem> workItems = listWorkItemsOfNode(node);
        Set<WorkItem> added = new LinkedHashSet<WorkItem>(Sets.difference(workItems, assignedWorkItems));
        Set<WorkItem> removed = new LinkedHashSet<WorkItem>(Sets.difference(assignedWorkItems, workItems));
        assignedWorkItems.addAll(added);
        assignedWorkItems.removeAll(removed);
View Full Code Here

Examples of io.fabric8.partition.WorkerNode

109
110
111
112
113
114
115
116
117
118
119
     * This method reads and returns that node.
     *
     * @return The {@link WorkerNode} that represents the Worker of the current container for the current task.
     */
    WorkerNode readWorkerNode() {
        WorkerNode node;
        String fullPath = ZkPath.TASK_MEMBER_PARTITIONS.getPath(name, context.getId());
        try {
            byte[] bytes = curator.getData().forPath(fullPath);
            if (bytes != null) {
                node = mapper.readValue(bytes, WorkerNode.class);
View Full Code Here

Examples of io.fabric8.partition.WorkerNode

125
126
127
128
129
130
131
132
        }
        return node;
    }

    WorkerNode createNode() {
        WorkerNode state = new WorkerNode(context.getId());
        return state;
    }
View Full Code Here

Examples of tv.floe.metronome.classification.neuralnetworks.iterativereduce.WorkerNode

123
124
125
126
127
128
129
130
131
132
133
134
    polr_ir.Setup();

    polr_ir.SimulateRun();

   
    WorkerNode singleWorker = (WorkerNode)polr_ir.getWorker().get(0);
    WorkerNode secondWorker = (WorkerNode)polr_ir.getWorker().get(1);
   
    MasterNode master = (MasterNode) polr_ir.getMaster();
   
    System.out.println("\n\nComplete: ");
    //Utils.PrintVector( master.polr.getBeta().viewRow(0) );
View Full Code Here

Examples of tv.floe.metronome.classification.neuralnetworks.iterativereduce.WorkerNode

100
101
102
103
104
105
106
107
108
109
110
    IRUnitDriver polr_ir = new IRUnitDriver("src/test/resources/run_profiles/unit_tests/nn/xor/app.unit_test.nn.xor.singlenode.properties");
    polr_ir.Setup();

    polr_ir.SimulateRun();

    WorkerNode singleWorker = (WorkerNode)polr_ir.getWorker().get(0);
   
    MasterNode master = (MasterNode) polr_ir.getMaster();
   
    System.out.println("\n\nComplete: ");
    //Utils.PrintVector( master.polr.getBeta().viewRow(0) );
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.