Examples of com.thinkaurelius.titan.core.TitanTransaction.commit()

Class com.thinkaurelius.titan.core.TitanTransaction

Examples of com.thinkaurelius.titan.core.TitanTransaction.commit()

com.thinkaurelius.titan.core.TitanTransaction.commit()
Commits and closes the transaction.
Will attempt to persist all modifications which may result in exceptions in case of persistence failures or lock contention.
The call releases data structures if possible. All element references (e.g. vertex objects) retrieved through this transaction are stale after the transaction closes and should no longer be used. @throws com.thinkaurelius.titan.diskstorage.StorageException if an error arises during persistence

                        for (int r = 0; r < repetitions; r++) {
                            assertEquals((int) Math.pow(numE, 2), Iterables.size(new GremlinPipeline<Vertex, Vertex>(v)
                                    .out(label).out(label)
                            ));
                        }
                        tx.commit();
                    }
                }
            });
            readThreads[t].start();
        }

View Full Code Here

            assertEquals((int) Math.pow(numE, 2), Iterables.size(
                    new GremlinPipeline<Vertex, Vertex>(v)
                            .out(label).out(label)
            ));
        }
        tx.commit();


        System.out.println("Time in ms for [" + (repetitions) + "] traversals in single tx: " + (System.currentTimeMillis() - start));
    }


    @Test

View Full Code Here

                            if (previous != null) {
                                v.addEdge("friend", previous).setProperty("time", Math.abs(random.nextInt()));
                            }
                            previous = v;
                        }
                        tx.commit();
                    }
                }
            });
            writeThreads[t].start();
        }

View Full Code Here

                        }
                        assertTrue(count <= 2);
//                        if (t%(trials/10)==0) System.out.println(t);
                    }
                    assertEquals(fixedName, tx.getVertex("uid", ruid).getProperty("name"));
                    tx.commit();
                }
            });
            readThreads[t].start();
        }
        for (int t = 0; t < readThreads.length; t++) {

View Full Code Here

0 1

TOP

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.