Package org.lab41.dendrite.metagraph

Examples of org.lab41.dendrite.metagraph.MetaGraphTx.commit()

144
145
146
147
148
149
150
151
152
153
154
                branches.add(new GetBranchResponse(branchMetadata));
            }

            return new GetBranchesResponse(branches);
        } finally {
            tx.commit();
        }
    }

    @PreAuthorize("hasPermission(#projectId, 'project', 'admin')")
    @RequestMapping(value = "/projects/{projectId}/branches/{branchName}", method = RequestMethod.GET)
View Full Code Here
168
169
170
171
172
173
174
175
176
177
178
                throw new NotFound(BranchMetadata.class, branchName);
            }

            return new GetBranchResponse(branchMetadata);
        } finally {
            tx.commit();
        }
    }

    @PreAuthorize("hasPermission(#projectId, 'project', 'admin')")
    @RequestMapping(value = "/projects/{projectId}/branches/{branchName}", method = RequestMethod.PUT)
View Full Code Here
243
244
245
246
247
248
249
250
251
252
253
            tx.rollback();
            throw t;
        }

        // Commit must come after all branch access.
        tx.commit();

        //taskExecutor.execute(branchCommitJob);
        branchCommitJob.run();

        return getBranchResponse;
View Full Code Here
80
81
82
83
84
85
86
87
88
89
90
        response.put("status", "ok");
        response.put("msg", "job submitted");
        response.put("jobId", jobMetadata.getId().toString());

        tx.commit();

        // We can't pass the values directly because they'll live in a separate thread.
        barycenterDistanceService.run(graph, jobMetadata.getId());

        return new ResponseEntity<>(response, HttpStatus.OK);
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
        response.put("status", "ok");
        response.put("msg", "job submitted");
        response.put("jobId", jobMetadata.getId().toString());

        tx.commit();

        // We can't pass the values directly because they'll live in a separate thread.
        betweennessCentralityService.run(graph, jobMetadata.getId());

        return new ResponseEntity<>(response, HttpStatus.OK);
View Full Code Here
171
172
173
174
175
176
177
178
179
180
181
        response.put("status", "ok");
        response.put("msg", "job submitted");
        response.put("jobId", jobMetadata.getId().toString());

        tx.commit();

        // We can't pass the values directly because they'll live in a separate thread.
        closenessCentralityService.run(graph, jobMetadata.getId());

        return new ResponseEntity<>(response, HttpStatus.OK);
View Full Code Here
216
217
218
219
220
221
222
223
224
225
226
        response.put("status", "ok");
        response.put("msg", "job submitted");
        response.put("jobId", jobMetadata.getId().toString());

        tx.commit();

        // We can't pass the values directly because they'll live in a separate thread.
        eigenvectorCentralityService.run(graph, jobMetadata.getId());

        return new ResponseEntity<>(response, HttpStatus.OK);
View Full Code Here
269
270
271
272
273
274
275
276
277
278
279
        response.put("status", "ok");
        response.put("msg", "job submitted");
        response.put("jobId", jobMetadata.getId().toString());

        tx.commit();

        // We can't pass the values directly because they'll live in a separate thread.
        pageRankService.run(graph, jobMetadata.getId(), item.getAlpha());

        return new ResponseEntity<>(response, HttpStatus.OK);
View Full Code Here
94
95
96
97
98
99
100
101
102
103
104
            branchMetadata = projectMetadata.getCurrentBranch();
            srcGraphMetadata = branchMetadata.getGraph();
            dstGraphMetadata = metaGraphTx.createGraph(srcGraphMetadata);
            jobMetadata = metaGraphTx.createJob(projectMetadata);
        } finally {
            metaGraphTx.commit();
        }

        projectId = projectMetadata.getId();
        branchId = branchMetadata.getId();
View Full Code Here
49
50
51
52
53
54
55
56
57
58
59
        } catch (Throwable t) {
            tx.rollback();
            throw t;
        }

        tx.commit();

        return getProjectsResponse;
    }

    @PreAuthorize("hasPermission(#projectId, 'project', 'admin')")
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.