List of addInsert() Examples

Examples of addInsert()

org.drools.core.common.LeftTupleSets.addInsert()
org.drools.core.common.LeftTupleSetsImpl.addInsert()
org.drools.core.common.RightTupleSets.addInsert()
org.openengsb.core.ekb.api.EKBCommit.addInsert()
Adds a model to the list of models which shall be inserted into the EDB. If the given object is not a model, an IllegalArgumentException is thrown.
org.xtreemfs.babudb.api.database.DatabaseInsertGroup.addInsert()
Add a new insert operation to this group. Be aware of unpredictable behavior if a key-value pair is manipulated twice within the same insert group. @param indexId - the index in which the key-value pair is inserted. @param key - the key. @param value - the value data.

Examples of org.xtreemfs.babudb.api.database.DatabaseInsertGroup.addInsert()

        byte[] data = new byte[2048];
        for (int i = 0; i < 1000; i++) {
            DatabaseInsertGroup ir = db.createInsertGroup();
            ir.addInsert(0, (i + "").getBytes(), data);
            ir.addInsert(1, (i + "").getBytes(), data);
            ir.addInsert(2, (i + "").getBytes(), data);
            db.insert(ir, null).get();
        }
        
        database.getCheckpointer().checkpoint();

View Full Code Here

Examples of org.xtreemfs.babudb.api.database.DatabaseInsertGroup.addInsert()

            0, COMPRESSION, maxNumRecs, maxBlockFileSize, !MMAP, -1, LOG_LEVEL));
        Database db = database.getDatabaseManager().createDatabase("test", 3);
        
        for (int i = 1000; i < 2000; i++) {
            DatabaseInsertGroup ir = db.createInsertGroup();
            ir.addInsert(0, (i + "").getBytes(), (i + "").getBytes());
            ir.addInsert(1, (i + "").getBytes(), (i + "").getBytes());
            ir.addInsert(2, (i + "").getBytes(), (i + "").getBytes());
            db.insert(ir, null);
        }

View Full Code Here

Examples of org.xtreemfs.babudb.api.database.DatabaseInsertGroup.addInsert()

        Database db = database.getDatabaseManager().createDatabase("test", 3);
        
        for (int i = 1000; i < 2000; i++) {
            DatabaseInsertGroup ir = db.createInsertGroup();
            ir.addInsert(0, (i + "").getBytes(), (i + "").getBytes());
            ir.addInsert(1, (i + "").getBytes(), (i + "").getBytes());
            ir.addInsert(2, (i + "").getBytes(), (i + "").getBytes());
            db.insert(ir, null);
        }
        
        Iterator<Entry<byte[], byte[]>> it = db.prefixLookup(0, new byte[0], null).get();

View Full Code Here

0 1 2 3 4 5

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.