Examples of org.apache.jackrabbit.oak.spi.state.NodeStore.merge()

Package org.apache.jackrabbit.oak.spi.state

Class org.apache.jackrabbit.oak.spi.state.NodeStore

Examples of org.apache.jackrabbit.oak.spi.state.NodeStore.merge()

org.apache.jackrabbit.oak.spi.state.NodeStore.merge()
Merges the changes from the passed {@code builder} intothe store. @param builder the builder whose changes to apply @param commitHook the commit hook to apply while merging changes @param info commit info associated with this merge operation,or {@code null} if no local commit information is available @return the node state resulting from the merge. @throws CommitFailedException if the merge failed @throws IllegalArgumentException if the builder is not acquiredfrom a root state of this store

        builder.child("testRoot").setProperty("foo", "abc")
                .setProperty("bar", "def");
        builder.child("testSecond").setProperty("bar", "ghi");


        // merge it back in
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        AsyncIndexUpdate async = new AsyncIndexUpdate("async", store, provider);
        async.run();
        NodeState root = store.getRoot();

View Full Code Here

        builder.child("testRoot").setProperty("foo", "abc");
        builder.child("newchild").child("other").child("testChild")
                .setProperty("foo", "xyz");


        // merge it back in
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        AsyncIndexUpdate async = new AsyncIndexUpdate("async", store, provider);
        async.run();
        NodeState root = store.getRoot();

View Full Code Here

        NodeBuilder builder = store.getRoot().builder();
        NodeBuilder c1 = builder.child("test-backup");
        c1.setProperty("blob", blob);
        NodeBuilder c2 = builder.child("test-backup2");
        c2.setProperty("blob", blob);
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        FileStoreBackup.backup(store, destination);
        compare(store, destination);
        source.close();

View Full Code Here

                "rootIndex", true, false, ImmutableSet.of("foo"), null)
                .setProperty(ASYNC_PROPERTY_NAME, "async");
        builder.child("testRoot").setProperty("foo", "abc");


        // merge it back in
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        AsyncIndexUpdate async = new AsyncIndexUpdate("async", store, provider);
        async.run();
        NodeState root = store.getRoot();

View Full Code Here

        builder.child("testRoot").setProperty("foo", "abc")
                .setProperty("bar", "def");
        builder.child("testSecond").setProperty("bar", "ghi");


        // merge it back in
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        AsyncIndexUpdate async = new AsyncIndexUpdate("async", store, provider);
        async.run();
        NodeState root = store.getRoot();

View Full Code Here

        builder.child("testRoot").setProperty("foo", "abc");
        builder.child("newchild").child("other").child("testChild")
                .setProperty("foo", "xyz");


        // merge it back in
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        AsyncIndexUpdate async = new AsyncIndexUpdate("async", store, provider);
        async.run();
        NodeState root = store.getRoot();

View Full Code Here

                Collections.singletonMap(ASYNC_PROPERTY_NAME, "async"));


        builder.child("test").setProperty("foo", "a");
        builder.child("child");


        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        final AsyncIndexUpdate async = new AsyncIndexUpdate("async", store,
                provider);
        async.run();

View Full Code Here

        async.run();


        builder = store.getRoot().builder();
        builder.child("test").setProperty("foo", "b");
        builder.child("child").setProperty("prop", "value");
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        Thread t = new Thread(new Runnable() {
            @Override
            public void run() {
                async.run();

View Full Code Here

        // wait until async update called checkpoint
        retrieve.release();
        checkpoint.acquireUninterruptibly();
        builder = store.getRoot().builder();
        builder.child("child").remove();
        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        // allow async update to proceed with NodeStore.retrieve()
        retrieve.release();
        t.join();

View Full Code Here

                false, ImmutableSet.of("foo"), null, TYPE,
                Collections.singletonMap(ASYNC_PROPERTY_NAME, "async"));


        builder.child("test").setProperty("foo", "a");


        store.merge(builder, EmptyHook.INSTANCE, CommitInfo.EMPTY);


        final AsyncIndexUpdate async = new AsyncIndexUpdate("async", store,
                provider);
        async.run();

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.